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