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)