Merge "Explicitly name subscription queue for responses"
This commit is contained in:
@@ -237,7 +237,7 @@ class DirectConsumer(ConsumerBase):
|
|||||||
elif conf.qpid_topology_version == 2:
|
elif conf.qpid_topology_version == 2:
|
||||||
node_name = "amq.direct/%s" % msg_id
|
node_name = "amq.direct/%s" % msg_id
|
||||||
node_opts = {}
|
node_opts = {}
|
||||||
link_name = None
|
link_name = msg_id
|
||||||
else:
|
else:
|
||||||
raise_invalid_topology_version(conf)
|
raise_invalid_topology_version(conf)
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user