fix all the exchanges
@@ -160,15 +160,19 @@ if __name__ == '__main__':
logger.info("Created message")
logger.info(decision)
+ exchange = 'topic-poseidon-internal'
+ exchange_type = 'topic'
connection = pika.BlockingConnection(pika.ConnectionParameters(
host='rabbit'))
channel = connection.channel()
- channel.exchange_declare(exchange='topic-poseidon-internal',
- exchange_type='topic')
+ channel.exchange_declare(exchange=exchange,
+ exchange_type=exchange_type)
routing_key = 'poseidon.algos.decider'
message = json.dumps(decision)
- channel.basic_publish(exchange='topic_logs',
+ channel.basic_publish(exchange=exchange,
routing_key=routing_key,
body=message)
+ print("Routing key: " + routing_key)
+ print("Exchange: " + exchange)
connection.close()
