openstack/oslo.messaging
Code Issues Proposed changes

Merge "Use default exchange for direct messaging"

Browse Source
This commit is contained in:
Zuul 2018-11-01 20:03:07 +00:00 committed by Gerrit Code Review
commit 1a781bd6dc
1 changed files with 2 additions and 1 deletions

3
oslo_messaging/_drivers/impl_rabbit.py

@ -1015,6 +1015,7 @@ class Connection(object):
responses for call/multicall
"""
# TODO(obondarev): use default exchange since T release
consumer = Consumer(exchange_name=topic,
queue_name=topic,
routing_key=topic,
@ -1181,7 +1182,7 @@ class Connection(object):
def direct_send(self, msg_id, msg):
"""Send a 'direct' message."""
exchange = kombu.entity.Exchange(name=msg_id,
exchange = kombu.entity.Exchange(name='', # using default exchange
type='direct',
durable=False,
auto_delete=True,