Merge "rabbit: Missing to pass parameter timeout to next"
This commit is contained in:
commit
7265a82a4e
@ -1086,7 +1086,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."""
|
||||
|
Loading…
x
Reference in New Issue
Block a user