diff options
| author | Zuul <zuul@review.opendev.org> | 2019-07-26 09:35:06 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2019-07-26 09:35:06 +0000 |
| commit | 002ac1453b2302b4885c4d0e37cc420bc30b4bb3 (patch) | |
| tree | 137f8fd5373fbf22fd94dafb1c56f1cb92179b88 | |
| parent | a5276be3dc519cc814dc18f4c8b80cd0728007a2 (diff) | |
| parent | 6fe1aec1c74f112db297cd727d2ea400a292b038 (diff) | |
| download | oslo-messaging-002ac1453b2302b4885c4d0e37cc420bc30b4bb3.tar.gz | |
Merge "Use default exchange for direct messaging"
| -rw-r--r-- | oslo_messaging/_drivers/impl_rabbit.py | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py index 124e7ef..d12430c 100644 --- 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, |