diff --git a/cinder/rpc.py b/cinder/rpc.py
index d5db4675eb8..60921a211e6 100644
--- a/cinder/rpc.py
+++ b/cinder/rpc.py
@@ -148,10 +148,9 @@ def get_client(target,
     if TRANSPORT is None:
         raise AssertionError('RPC transport is not initialized.')
     serializer = RequestContextSerializer(serializer)
-    return messaging.RPCClient(TRANSPORT,
-                               target,
-                               version_cap=version_cap,
-                               serializer=serializer)
+    return messaging.get_rpc_client(
+        TRANSPORT, target, version_cap=version_cap,
+        serializer=serializer)
 
 
 def get_server(target,
diff --git a/requirements.txt b/requirements.txt
index 10b066d5c55..717f26f0e10 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -19,7 +19,7 @@ oslo.concurrency>=4.5.0 # Apache-2.0
 oslo.context>=3.4.0 # Apache-2.0
 oslo.db>=11.0.0 # Apache-2.0
 oslo.log>=4.6.1 # Apache-2.0
-oslo.messaging>=12.5.0 # Apache-2.0
+oslo.messaging>=14.1.0 # Apache-2.0
 oslo.middleware>=4.1.1 # Apache-2.0
 oslo.policy>=3.8.1 # Apache-2.0
 oslo.privsep>=2.6.2 # Apache-2.0