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(
routing_key='control.tun.toAgent.agent1', exchange=AMQP_EXCHANGE,
mandatory=True, routing_key='control.tun.toAgent.agent1',
body=json.dumps(d)) mandatory=True,
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(
routing_key='control.tun.toAgent.agent2', exchange=AMQP_EXCHANGE,
mandatory=True, routing_key='control.tun.toAgent.agent2',
body=json.dumps(d)) mandatory=True,
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(
routing_key='control.tun.toAgent.agent_TT', exchange=AMQP_EXCHANGE,
mandatory=True, routing_key='control.tun.toAgent.agent_TT',
body=json.dumps(d)) mandatory=True,
\ No newline at end of file properties=pika.BasicProperties(
content_type='application/json',
),
body=json.dumps(d)
)