fix: qpid support

ICIJ · Nov 29, 2024 · 3c8dd1b · 3c8dd1b
1 parent b9a9c7e
commit 3c8dd1b
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/icij-worker/icij_worker/utils/amqp.py b/icij-worker/icij_worker/utils/amqp.py
@@ -308,13 +308,14 @@ async def _create_routing(
             dlx_name = routing.dead_letter_routing.exchange.name
             dl_routing_key = routing.dead_letter_routing.routing_key
             # TODO: this could be passed through policy
-            if not self._is_qpid:
-                update = {
-                    "x-dead-letter-exchange": dlx_name,
-                    "x-dead-letter-routing-key": dl_routing_key,
-                }
-                queue_args.update(update)
+            update = {
+                "x-dead-letter-exchange": dlx_name,
+                "x-dead-letter-routing-key": dl_routing_key,
+            }
+            queue_args.update(update)
         if declare_queues:
+            if self._is_qpid:
+                queue_args = dict()
             queue = await self._channel.declare_queue(
                 routing.queue_name, durable=durable_queues, arguments=queue_args
             )