openstack/oslo.messaging
Code Issues Proposed changes

rabbit: Missing to pass parameter timeout to next

Browse Source 
Missing to pass parameter 'timeout' to the method '_ensure_publishing'
when publishing a message.

That will cause RPCClient.call unable to pass timeout to the underlying.

Change-Id: I1abc7e9c6f5204fa336f29a94114c18d8b982fcb
This commit is contained in:
Javeme 2016-01-05 19:21:44 +08:00
parent 7c723afd0a
commit 3d4babe900
1 changed files with 2 additions and 1 deletions

3
oslo_messaging/_drivers/impl_rabbit.py

@ -1091,7 +1091,8 @@ class Connection(object):
auto_delete=self.amqp_auto_delete)
self._ensure_publishing(self._publish, exchange, msg,
routing_key=topic, retry=retry)
routing_key=topic, timeout=timeout,
retry=retry)
def fanout_send(self, topic, msg, retry=None):
"""Send a 'fanout' message."""