openstack
/
oslo.messaging
Code Issues Proposed changes

Merge "Use default exchange for direct messaging"

This commit is contained in:
Zuul 2018-11-01 20:03:07 +00:00 committed by Gerrit Code Review
parent 7b6e2e49e3 3a5de89dd6
commit 1a781bd6dc
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
oslo_messaging/_drivers/impl_rabbit.py
View File

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