From 3d4babe900d76bdc6d23d236a916e218e457c08d Mon Sep 17 00:00:00 2001
From: Javeme <zhangmei.li@easystack.cn>
Date: Tue, 5 Jan 2016 19:21:44 +0800
Subject: [PATCH] rabbit: Missing to pass parameter timeout to next
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
---
oslo_messaging/_drivers/impl_rabbit.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py
index 1f75b3349..359f47050 100644
--- a/oslo_messaging/_drivers/impl_rabbit.py
+++ b/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."""