Merge "Use default exchange for direct messaging"

2019-07-26 09:35:06 +00:00 · 2019-07-26 09:35:06 +00:00 · 002ac1453b
commit 002ac1453b
parent a5276be3dc 6fe1aec1c7
1 changed files with 3 additions and 4 deletions
--- a/oslo_messaging/_drivers/impl_rabbit.py
+++ b/oslo_messaging/_drivers/impl_rabbit.py
@ -1063,13 +1063,12 @@ class Connection(object):
        responses for call/multicall
        """

-        # TODO(obondarev): use default exchange since T release
-        consumer = Consumer(exchange_name=topic,
+        consumer = Consumer(exchange_name='',  # using default exchange
                            queue_name=topic,
-                            routing_key=topic,
+                            routing_key='',
                            type='direct',
                            durable=False,
-                            exchange_auto_delete=True,
+                            exchange_auto_delete=False,
                            queue_auto_delete=False,
                            callback=callback,
                            rabbit_ha_queues=self.rabbit_ha_queues,