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."""