diff options
| author | Jenkins <jenkins@review.openstack.org> | 2014-07-24 23:48:07 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2014-07-24 23:48:07 +0000 |
| commit | afe191c32b73f218ec6538a9a1ef62e743fe528a (patch) | |
| tree | e4375f6143cd2c1d2cf58d246c6922997416f422 | |
| parent | 36e3e9931f27e948721ff1d6f59a9ee6cc17c8b0 (diff) | |
| parent | f09b9550c8269376f32a8dc05c5efc615619c903 (diff) | |
| download | oslo-messaging-afe191c32b73f218ec6538a9a1ef62e743fe528a.tar.gz | |
Merge "Explicitly name subscription queue for responses" into stable/icehouse1.3.1
| -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 41e780e..274c4b3 100644 --- a/oslo/messaging/_drivers/impl_qpid.py +++ b/oslo/messaging/_drivers/impl_qpid.py @@ -234,7 +234,7 @@ class DirectConsumer(ConsumerBase): elif conf.qpid_topology_version == 2: node_name = "amq.direct/%s" % msg_id node_opts = {} - link_name = None + link_name = msg_id else: raise_invalid_topology_version(conf) |