diff --git a/octavia/api/v2/controllers/amphora.py b/octavia/api/v2/controllers/amphora.py
index c91ec6b9f5..6882137c2f 100644
--- a/octavia/api/v2/controllers/amphora.py
+++ b/octavia/api/v2/controllers/amphora.py
@@ -176,11 +176,10 @@ class AmphoraUpdateController(base.BaseController):
         else:
             topic = constants.TOPIC_AMPHORA_V2
             version = "2.0"
-        self.transport = messaging.get_rpc_transport(cfg.CONF)
         self.target = messaging.Target(
             namespace=constants.RPC_NAMESPACE_CONTROLLER_AGENT,
             topic=topic, version=version, fanout=False)
-        self.client = messaging.RPCClient(self.transport, target=self.target)
+        self.client = rpc.get_client(self.target)
         self.amp_id = amp_id
 
     @wsme_pecan.wsexpose(None, wtypes.text, status_code=202)
diff --git a/octavia/common/rpc.py b/octavia/common/rpc.py
index fb7bf63f0c..784e91899d 100644
--- a/octavia/common/rpc.py
+++ b/octavia/common/rpc.py
@@ -47,11 +47,10 @@ def get_client(target, version_cap=None, serializer=None,
 
     assert TRANSPORT is not None, _("'TRANSPORT' must not be None")
 
-    return messaging.RPCClient(TRANSPORT,
-                               target,
-                               version_cap=version_cap,
-                               serializer=serializer,
-                               call_monitor_timeout=call_monitor_timeout)
+    return messaging.get_rpc_client(
+        TRANSPORT, target, version_cap=version_cap,
+        serializer=serializer,
+        call_monitor_timeout=call_monitor_timeout)
 
 
 def get_server(target, endpoints, executor='threading',
diff --git a/octavia/tests/functional/api/v2/test_load_balancer.py b/octavia/tests/functional/api/v2/test_load_balancer.py
index 0342efeeed..17fd957b0f 100644
--- a/octavia/tests/functional/api/v2/test_load_balancer.py
+++ b/octavia/tests/functional/api/v2/test_load_balancer.py
@@ -1040,7 +1040,7 @@ class TestLoadBalancer(base.BaseAPITest):
                 ".get_network") as mock_get_network, mock.patch(
                 'oslo_messaging.get_rpc_transport'), mock.patch(
                 'oslo_messaging.Target'), mock.patch(
-                'oslo_messaging.RPCClient'):
+                'oslo_messaging.get_rpc_client'):
             mock_get_network.return_value = mock.MagicMock()
             mock_get_network.return_value.port_security_enabled = True
             response = self.post(self.LBS_PATH, body)
@@ -1061,7 +1061,7 @@ class TestLoadBalancer(base.BaseAPITest):
                 ".get_network") as mock_get_network, mock.patch(
                 'oslo_messaging.get_rpc_transport'), mock.patch(
                 'oslo_messaging.Target'), mock.patch(
-                'oslo_messaging.RPCClient'):
+                'oslo_messaging.get_rpc_client'):
             mock_get_network.return_value = mock.MagicMock()
             mock_get_network.return_value.port_security_enabled = False
             response = self.post(self.LBS_PATH, body, status=500)
diff --git a/requirements.txt b/requirements.txt
index 15b546ea32..872c355b6f 100644
--- a/requirements.txt
+++ b/requirements.txt
@@ -24,7 +24,7 @@ oslo.context>=2.22.0 # Apache-2.0
 oslo.db[mysql]>=8.4.0 # Apache-2.0
 oslo.i18n>=3.20.0 # Apache-2.0
 oslo.log>=4.3.0 # Apache-2.0
-oslo.messaging>=12.4.0 # Apache-2.0
+oslo.messaging>=14.1.0 # Apache-2.0
 oslo.middleware>=4.0.1 # Apache-2.0
 oslo.policy>=3.7.0 # Apache-2.0
 oslo.reports>=1.18.0 # Apache-2.0