diff options
| author | Gordon Sim <gsim@redhat.com> | 2014-03-31 17:35:04 +0100 |
|---|---|---|
| committer | Russell Bryant <rbryant@redhat.com> | 2014-06-09 16:40:43 -0400 |
| commit | 5c00c9c562803446b39e254fb477cd4fdbae374f (patch) | |
| tree | 5c7390bc5609136b372ed319c306fa463f24c011 | |
| parent | e0933b4258417f2fcd945948f64217fc7a11ea8f (diff) | |
| download | oslo-messaging-5c00c9c562803446b39e254fb477cd4fdbae374f.tar.gz | |
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
(cherry picked from commit 9e0e85ede8406ace45c7573b18b8fe86c3e58921)
| -rw-r--r-- | oslo/messaging/_drivers/impl_qpid.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/oslo/messaging/_drivers/impl_qpid.py b/oslo/messaging/_drivers/impl_qpid.py index 54efc5d..41e780e 100644 --- a/oslo/messaging/_drivers/impl_qpid.py +++ b/oslo/messaging/_drivers/impl_qpid.py @@ -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 |