opensource/galaxy
3
0
Fork 0
mirror of https://github.com/galaxyproject/galaxy.git synced 2026-10-24 23:49:37 +08:00
Code Issues Packages Projects Releases Wiki Activity

Exchange routing key needs to be wildcard ...

Browse Source 
But why that wasn't a problem before is a mystery to me.
This commit is contained in:
mvdbeek
2020-03-25 16:02:35 +01:00
parent 1604f2ab28
commit 7d110f1d71
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/galaxy/queues.py
+1 -1
View File
@@ -32,7 +32,7 @@ def control_queues_from_config(config):
"""
hostname = socket.gethostname()
process_name = "{server_name}@{hostname}".format(server_name=config.server_name, hostname=hostname)
exchange_queue = Queue("control.%s" % process_name, galaxy_exchange, routing_key='control.%s' % process_name)
exchange_queue = Queue("control.%s" % process_name, galaxy_exchange, routing_key='control.*')
non_exchange_queue = Queue("control.%s" % process_name, routing_key='control.%s' % process_name)
return exchange_queue, non_exchange_queue