From 9ccfbdd3c3b19419c370b041c0f39be6b70b622d Mon Sep 17 00:00:00 2001
From: Gevorg Davoian <gdavoian@mirantis.com>
Date: Tue, 24 May 2016 12:32:11 +0300
Subject: [PATCH] Fix problems after refactoring RPC client

The patch fixes some problems arised after merging the previous
patch which this patch depends on.

Change-Id: If38edec19f9bffc8ac54818b2536243a9edaf7e8
Depends-On: I608c828123b196099933d16801f8ce7d9dd3a079
Closes-Bug: #1584889
---
 oslo_messaging/rpc/client.py | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/oslo_messaging/rpc/client.py b/oslo_messaging/rpc/client.py
index 63f388cf4..88e21a549 100644
--- a/oslo_messaging/rpc/client.py
+++ b/oslo_messaging/rpc/client.py
@@ -383,7 +383,7 @@ class RPCClient(_BaseCallContext):
         :type kwargs: dict
         :raises: MessageDeliveryFailure
         """
-        super(RPCClient, self).cast(ctxt, method, **kwargs)
+        self.prepare().cast(ctxt, method, **kwargs)
 
     def call(self, ctxt, method, **kwargs):
         """Invoke a method and wait for a reply.
@@ -425,8 +425,8 @@ class RPCClient(_BaseCallContext):
         :type kwargs: dict
         :raises: MessagingTimeout, RemoteError, MessageDeliveryFailure
         """
-        return super(RPCClient, self).call(ctxt, method, **kwargs)
+        return self.prepare().call(ctxt, method, **kwargs)
 
     def can_send_version(self, version=_marker):
         """Check to see if a version is compatible with the version cap."""
-        return super(RPCClient, self).can_send_version(version)
+        return self.prepare(version=version).can_send_version()