Commit 591ade86 authored by Federico Sismondi's avatar Federico Sismondi

fix for multiple ongoing agent config (overlapping queue names)

parent 879c61c4
...@@ -68,7 +68,7 @@ def check_response(channel, queue_name, agent_id): ...@@ -68,7 +68,7 @@ def check_response(channel, queue_name, agent_id):
def bootstrap(amqp_url, amqp_exchange, agent_id, ipv6_host, ipv6_prefix, ipv6_no_forwarding): def bootstrap(amqp_url, amqp_exchange, agent_id, ipv6_host, ipv6_prefix, ipv6_no_forwarding):
connection = pika.BlockingConnection(pika.connection.URLParameters(amqp_url)) connection = pika.BlockingConnection(pika.connection.URLParameters(amqp_url))
channel = connection.channel() channel = connection.channel()
agent_event_q = 'agent_bootstrap' agent_event_q = 'agent_bootstrap|%s' % agent_id
result = channel.queue_declare(queue=agent_event_q, auto_delete=True) result = channel.queue_declare(queue=agent_event_q, auto_delete=True)
callback_queue = result.method.queue callback_queue = result.method.queue
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment