self/sprint
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

pika

Browse Source
This commit is contained in:
Administrator 2022-08-16 13:43:20 +03:00
parent 1285a770fc
commit 2fdd477bda
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
SprintLib/queue.py
View File

@ -13,7 +13,11 @@ from Sprint import settings
def send_to_queue(queue_name, payload): def send_to_queue(queue_name, payload):
with pika.BlockingConnection( 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: ) as connection:
channel = connection.channel() channel = connection.channel()
channel.queue_declare(queue=queue_name) channel.queue_declare(queue=queue_name)