openstack
/
oslo.messaging
Code Issues Proposed changes

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
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
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
oslo_messaging/_drivers/impl_rabbit.py
View File

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