openstack/oslo.messaging
Code Issues Proposed changes

Fix problems after refactoring RPC client

Browse Source 
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
This commit is contained in:
Gevorg Davoian 2016-05-24 12:32:11 +03:00
parent 7809cdc602
commit 9ccfbdd3c3
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
oslo_messaging/rpc/client.py
View File

@ -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()