diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py index d34373676..00484d695 100644 --- a/oslo_messaging/_drivers/impl_rabbit.py +++ b/oslo_messaging/_drivers/impl_rabbit.py @@ -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."""