Merge "Ensure routing key is specified in the address for a direct producer" into stable/icehouse
This commit is contained in:
commit
4020d018cd
|
@ -368,7 +368,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
|
||||
|
|
Loading…
Reference in New Issue