From cc757e145539c80a0f804bbaf71ed62a574ecbf1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Torma=20Krist=C3=B3f?= Date: Mon, 13 Apr 2020 16:22:12 +0200 Subject: [PATCH] use fanout exchange --- src/rabbitmqqueue.py | 1 + 1 file changed, 1 insertion(+) diff --git a/src/rabbitmqqueue.py b/src/rabbitmqqueue.py index adf7431..c1227a6 100644 --- a/src/rabbitmqqueue.py +++ b/src/rabbitmqqueue.py @@ -15,4 +15,5 @@ __version__text__ = "1" credentials = pika.PlainCredentials(RABBITMQ_USERNAME, RABBITMQ_PASSWORD) rabbitmq = pika.BlockingConnection(pika.ConnectionParameters(host=RABBITMQ_HOST, credentials=credentials)) rabbitmq_channel = rabbitmq.channel() +rabbitmq_channel.exchange_declare(exchange=RABBITMQ_EXCHANGE, exchange_type='fanout') rabbitmq_channel.queue_declare(RABBITMQ_QUEUE) \ No newline at end of file