diff options
| author | Tobias Urdin <tobias.urdin@binero.se> | 2023-01-12 07:24:41 +0000 |
|---|---|---|
| committer | Balazs Gibizer <gibi@redhat.com> | 2023-01-17 15:06:41 +0100 |
| commit | c59db128a00477f6163d71ea1454da4286dad708 (patch) | |
| tree | 52c778bb71360d868ce97c3520a11a2f3864a010 /nova/rpc.py | |
| parent | 668d4e590f7b22c930772c00a16dc4b289d8745c (diff) | |
| download | nova-c59db128a00477f6163d71ea1454da4286dad708.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: If1128fe0faacef757ed10023c00a67e5ec0440bd
Diffstat (limited to 'nova/rpc.py')
| -rw-r--r-- | nova/rpc.py | 16 |
1 files changed, 7 insertions, 9 deletions
diff --git a/nova/rpc.py b/nova/rpc.py index a32b920e06..7a92650414 100644 --- a/nova/rpc.py +++ b/nova/rpc.py @@ -204,11 +204,9 @@ def get_client(target, version_cap=None, serializer=None, else: serializer = RequestContextSerializer(serializer) - 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, serializer=None): @@ -436,9 +434,9 @@ class ClientRouter(periodic_task.PeriodicTasks): transport = context.mq_connection if transport: cmt = self.default_client.call_monitor_timeout - return messaging.RPCClient(transport, self.target, - version_cap=self.version_cap, - serializer=self.serializer, - call_monitor_timeout=cmt) + return messaging.get_rpc_client(transport, self.target, + version_cap=self.version_cap, + serializer=self.serializer, + call_monitor_timeout=cmt) else: return self.default_client |