summaryrefslogtreecommitdiff
path: root/trove
diff options
context:
space:
mode:
authorTobias Urdin <tobias.urdin@binero.se>2023-01-19 20:45:49 +0000
committerwu.chunyang <wchy1001@gmail.com>2023-03-06 11:59:57 +0000
commit4b9c3d3079d558eec5e17b264d9064c443812959 (patch)
tree363570d2eabb49d05185cd47addb3d28bad13249 /trove
parentce5956d61adceb1251d1d31a72825cbcf5f859bb (diff)
downloadtrove-4b9c3d3079d558eec5e17b264d9064c443812959.tar.gz
Use new get_rpc_client API from oslo.messaging
Use the new API that is consistent with the existing API instead of instantiating the client class directly. This was introduced in release 14.1.0 here [1] and added into oslo.messaging here [2] [1] https://review.opendev.org/c/openstack/requirements/+/869340 [2] https://review.opendev.org/c/openstack/oslo.messaging/+/862419 Change-Id: Ia0178e905654aaf0d05c7396867332ea5a661760
Diffstat (limited to 'trove')
-rw-r--r--trove/rpc.py7
1 files changed, 3 insertions, 4 deletions
diff --git a/trove/rpc.py b/trove/rpc.py
index 81a9b2fb..36fa5b21 100644
--- a/trove/rpc.py
+++ b/trove/rpc.py
@@ -103,10 +103,9 @@ def get_client(target, key, version_cap=None, serializer=None,
# assert key is not None
serializer = secure_serializer(
sz.TroveRequestContextSerializer(serializer), key)
- 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, endpoints, key, serializer=None,