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:
Gordon Sim 2014-05-20 15:59:50 +01:00
parent 17162dc6db
commit e29b8aa672
1 changed files with 1 additions and 1 deletions

View File

@ -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()