summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJenkins <jenkins@review.openstack.org>2014-07-23 12:56:01 +0000
committerGerrit Code Review <review@openstack.org>2014-07-23 12:56:01 +0000
commit8bcb60fe5d6bfbb476ab3fa939ed7390c3c4cfb8 (patch)
treee87addc6a1960112049d8cacde36426ff1148837
parent4e87fc6a65e9317603e368c5a15357db565456f7 (diff)
parentc2d61ec7ca037358c9cea32d264a5ef64086ba09 (diff)
downloadceilometer-8bcb60fe5d6bfbb476ab3fa939ed7390c3c4cfb8.tar.gz
Merge "Ensure routing key is specified in the address for a direct producer" into stable/havana
-rw-r--r--ceilometer/openstack/common/rpc/impl_qpid.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/ceilometer/openstack/common/rpc/impl_qpid.py b/ceilometer/openstack/common/rpc/impl_qpid.py
index a0caabd3..a697d911 100644
--- a/ceilometer/openstack/common/rpc/impl_qpid.py
+++ b/ceilometer/openstack/common/rpc/impl_qpid.py
@@ -369,7 +369,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