diff --git a/swagger_server/messaging/topic_queue_consumer.py b/swagger_server/messaging/topic_queue_consumer.py index 5e667c7..6b90123 100644 --- a/swagger_server/messaging/topic_queue_consumer.py +++ b/swagger_server/messaging/topic_queue_consumer.py @@ -43,7 +43,7 @@ def __init__(self, thread_queue, exchange_name): self.channel = self.connection.channel() self.exchange_name = exchange_name - self.result = self.channel.queue_declare(queue=SUB_QUEUE) + self.result = self.channel.queue_declare(queue="", exclusive=True) self._thread_queue = thread_queue self.binding_keys = []