Skip to content

Commit

Permalink
Merge pull request #115 from atlanticwave-sdx/update-topic-queue-name
Browse files Browse the repository at this point in the history
Use empty queue name
  • Loading branch information
congwang09 authored Apr 8, 2024
2 parents ffe52a2 + ff3ba6f commit a22df35
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion swagger_server/messaging/topic_queue_consumer.py
Original file line number Diff line number Diff line change
Expand Up @@ -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 = []
Expand Down

0 comments on commit a22df35

Please sign in to comment.