Explicitly name subscription queue
This ensures that on reconnect the same queue is used rather than leaving it abandoned but still bound with the same routing key that will be used with the new queue. Change-Id: Ib76371a3b649688df395d7bf07f813a837b2313a Closes-Bug: 1318742
This commit is contained in:
parent
17162dc6db
commit
e29b8aa672
|
@ -224,7 +224,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()
|
||||
|
||||
|
|
Loading…
Reference in New Issue