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