Commit 9bc9a5da authored by Federico Sismondi's avatar Federico Sismondi
Browse files

added content type of amqp messages ( kombu doesnt desirialize message if this...

added content type of amqp messages ( kombu doesnt desirialize message if this field it's not present)
parent 9dc16e46
......@@ -46,19 +46,35 @@ d = {
logging.debug("Let's start the bootstrap the agents")
channel.basic_publish(exchange='default',
routing_key='control.tun.toAgent.agent1',
mandatory=True,
body=json.dumps(d))
channel.basic_publish(
exchange=AMQP_EXCHANGE,
routing_key='control.tun.toAgent.agent1',
mandatory=True,
properties=pika.BasicProperties(
content_type='application/json',
),
body=json.dumps(d)
)
d["ipv6_host"] = ":2"
channel.basic_publish(exchange='default',
routing_key='control.tun.toAgent.agent2',
mandatory=True,
body=json.dumps(d))
channel.basic_publish(
exchange=AMQP_EXCHANGE,
routing_key='control.tun.toAgent.agent2',
mandatory=True,
properties=pika.BasicProperties(
content_type='application/json',
),
body=json.dumps(d)
)
d["ipv6_host"] = ":3"
channel.basic_publish(exchange='default',
routing_key='control.tun.toAgent.agent_TT',
mandatory=True,
body=json.dumps(d))
\ No newline at end of file
channel.basic_publish(
exchange=AMQP_EXCHANGE,
routing_key='control.tun.toAgent.agent_TT',
mandatory=True,
properties=pika.BasicProperties(
content_type='application/json',
),
body=json.dumps(d)
)
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