fixed bug

NOAA-GSL · Oct 30, 2024 · 27f5a95 · 27f5a95
1 parent 8a03a00
commit 27f5a95
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/python/idsse_common/idsse/common/rabbitmq_utils.py b/python/idsse_common/idsse/common/rabbitmq_utils.py
@@ -206,7 +206,7 @@ def subscribe_to_queue(
 
 def _setup_exch_and_queue(channel: Channel, exch: Exch, queue: Queue):
     """Setup an exchange and queue and bind them with the queue's route key(s)"""
-    if queue.type == 'quorum' and queue.auto_delete:
+    if queue.arguments['x-queue-type'] == 'quorum' and queue.auto_delete:
         raise ValueError('Quorum queues can not be configured to auto delete')
 
     _setup_exch(channel, exch)