openstack/oslo.messaging
Code Issues Proposed changes

Use default exchange for direct messaging

Browse Source 
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
This commit is contained in:
Oleg Bondarev 2019-07-04 16:08:45 +04:00
parent 6cdd4cb007
commit 6fe1aec1c7
1 changed files with 3 additions and 4 deletions

7
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,