diff options
| author | Oleg Bondarev <obondarev@mirantis.com> | 2019-07-04 16:08:45 +0400 |
|---|---|---|
| committer | Oleg Bondarev <obondarev@mirantis.com> | 2019-07-04 19:47:25 +0400 |
| commit | 6fe1aec1c74f112db297cd727d2ea400a292b038 (patch) | |
| tree | 3579e4f9f65f9f23c686a68d07d9dc21f536ea92 /oslo_messaging/_drivers/impl_rabbit.py | |
| parent | 6cdd4cb00779acd5b5825b5f00635af08f92a5df (diff) | |
| download | oslo-messaging-6fe1aec1c74f112db297cd727d2ea400a292b038.tar.gz | |
Use default exchange for direct messaging
Lots of exchanges create problems during failover under high
load. Please see bug report for details.
This is a step 2 patch.
Step 1 was: only using default exchange
when publishing.
Step 2 is to update consumers to only listen on default exchange,
happening now in T release.
Change-Id: Ib2ba62a642e6ce45c23568daeef9703a647707f3
Closes-Bug: #1789177
Diffstat (limited to 'oslo_messaging/_drivers/impl_rabbit.py')
| -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 1726fec..fda9f0b 100644 --- a/oslo_messaging/_drivers/impl_rabbit.py +++ b/oslo_messaging/_drivers/impl_rabbit.py @@ -1053,13 +1053,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, |