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

variables

Browse Source
This commit is contained in:
Egor Matveev
2022-05-01 09:11:25 +03:00
parent 8a19232671
commit 8ec2fa08ea
3 changed files with 49 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
SprintLib/queue.py
View File

@@ -39,13 +39,13 @@ class MessagingSupport(BaseCommand):
print("start listening " + self.queue_name)
while True:
try:
connection = pika.BlockingConnection(
with pika.BlockingConnection(
pika.ConnectionParameters(host=settings.RABBIT_HOST)
)
channel = connection.channel()
channel.queue_declare(queue=self.queue_name)
channel.basic_consume(queue=self.queue_name, on_message_callback=self.consume, auto_ack=True)
channel.start_consuming()
) as connection:
channel = connection.channel()
channel.queue_declare(queue=self.queue_name)
channel.basic_consume(queue=self.queue_name, on_message_callback=self.consume, auto_ack=True)
channel.start_consuming()
except AMQPConnectorException:
print("connection to rabbit failed: reconnecting")