openstack
/
oslo.messaging
Code Issues Proposed changes

Ensure routing key is specified in the address for a direct producer 

This then matches the address used a direct consumer.

Change-Id: If71f78e50f8a9b3acfd1e9d02c8271f17c4ebee7
Closes-Bug: #1300318
This commit is contained in:
Gordon Sim 2014-03-31 17:35:04 +01:00
parent 19053b6e65
commit 9e0e85ede8
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
oslo/messaging/_drivers/impl_qpid.py
View File

@ -378,7 +378,7 @@ class DirectPublisher(Publisher):
"""Init a 'direct' publisher."""
if conf.qpid_topology_version == 1:
node_name = msg_id
node_name = "%s/%s" % (msg_id, msg_id)
node_opts = {"type": "direct"}
elif conf.qpid_topology_version == 2:
node_name = "amq.direct/%s" % msg_id