From fd22ec57eb98beaf00be8b3ddc691cb83481b66c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Torma=20Krist=C3=B3f?= Date: Thu, 30 Jul 2020 15:39:02 +0200 Subject: [PATCH] auto delete queue --- src/app.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/app.py b/src/app.py index ca2ebf1..99f1231 100644 --- a/src/app.py +++ b/src/app.py @@ -45,7 +45,7 @@ def setup_rabbit() -> None: exchange_type='fanout', durable=True, auto_delete=False) - queue = channel.queue_declare(durable=True, auto_delete=False, queue=uuid.uuid4().urn.split(':')[2], + queue = channel.queue_declare(durable=True, auto_delete=True, queue=uuid.uuid4().urn.split(':')[2], exclusive=True).method.queue channel.queue_bind(exchange=config.RABBIT_EXCHANGE, queue=queue) channel.basic_consume(queue=queue, on_message_callback=on_message, auto_ack=True)