diff --git a/SprintLib/queue.py b/SprintLib/queue.py index 5154560..df6576c 100644 --- a/SprintLib/queue.py +++ b/SprintLib/queue.py @@ -13,7 +13,11 @@ from Sprint import settings def send_to_queue(queue_name, payload): with pika.BlockingConnection( - pika.ConnectionParameters(host=settings.RABBIT_HOST, port=settings.RABBIT_PORT) + pika.ConnectionParameters( + host=settings.RABBIT_HOST, + port=settings.RABBIT_PORT, + credentials=pika.PlainCredentials('guest', settings.RABBIT_PASSWORD) + ) ) as connection: channel = connection.channel() channel.queue_declare(queue=queue_name)