diff options
| author | Zuul <zuul@review.openstack.org> | 2018-11-01 20:03:07 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2018-11-01 20:03:07 +0000 |
| commit | 1a781bd6dca5f56593c530be9707e48bccff8e0c (patch) | |
| tree | 130051d49d5945fabed4782c605e5e71985f5a49 | |
| parent | 7b6e2e49e3e6dea601dc5bd789ab07e0cea507cd (diff) | |
| parent | 3a5de89dd686dbd9660f140fdddd9c78b20e1632 (diff) | |
| download | oslo-messaging-1a781bd6dca5f56593c530be9707e48bccff8e0c.tar.gz | |
Merge "Use default exchange for direct messaging"9.2.0
| -rw-r--r-- | oslo_messaging/_drivers/impl_rabbit.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py index 17b6bab..e2ac5e1 100644 --- a/oslo_messaging/_drivers/impl_rabbit.py +++ b/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, |