Commits (1)
...@@ -46,19 +46,35 @@ d = { ...@@ -46,19 +46,35 @@ d = {
logging.debug("Let's start the bootstrap the agents") logging.debug("Let's start the bootstrap the agents")
channel.basic_publish(exchange='default', channel.basic_publish(
exchange=AMQP_EXCHANGE,
routing_key='control.tun.toAgent.agent1', routing_key='control.tun.toAgent.agent1',
mandatory=True, mandatory=True,
body=json.dumps(d)) properties=pika.BasicProperties(
content_type='application/json',
),
body=json.dumps(d)
)
d["ipv6_host"] = ":2" d["ipv6_host"] = ":2"
channel.basic_publish(exchange='default', channel.basic_publish(
exchange=AMQP_EXCHANGE,
routing_key='control.tun.toAgent.agent2', routing_key='control.tun.toAgent.agent2',
mandatory=True, mandatory=True,
body=json.dumps(d)) properties=pika.BasicProperties(
content_type='application/json',
),
body=json.dumps(d)
)
d["ipv6_host"] = ":3" d["ipv6_host"] = ":3"
channel.basic_publish(exchange='default', channel.basic_publish(
exchange=AMQP_EXCHANGE,
routing_key='control.tun.toAgent.agent_TT', routing_key='control.tun.toAgent.agent_TT',
mandatory=True, mandatory=True,
body=json.dumps(d)) properties=pika.BasicProperties(
\ No newline at end of file content_type='application/json',
),
body=json.dumps(d)
)