From 85b306e6aded1f3a36c7d167c721bfdeb899ff02 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Torma=20Krist=C3=B3f?= Date: Mon, 13 Apr 2020 17:06:01 +0200 Subject: [PATCH] remove queue declare --- src/rabbitmqqueue.py | 1 - 1 file changed, 1 deletion(-) diff --git a/src/rabbitmqqueue.py b/src/rabbitmqqueue.py index c1227a6..1ad8dcf 100644 --- a/src/rabbitmqqueue.py +++ b/src/rabbitmqqueue.py @@ -16,4 +16,3 @@ 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