fix: qpid support

ICIJ · Nov 29, 2024 · 099ae28 · 099ae28
1 parent f0c5858
commit 099ae28
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/icij-worker/icij_worker/event_publisher/amqp.py b/icij-worker/icij_worker/event_publisher/amqp.py
@@ -27,9 +27,9 @@ def __init__(
         broker_url: str,
         connection_timeout_s: float = 1.0,
         reconnection_wait_s: float = 5.0,
+        is_qpid: bool = False,
         app_id: Optional[str] = None,
         connection: Optional[AbstractRobustConnection] = None,
-        is_qpid: bool = False,
     ):
         super().__init__(
             broker_url,

diff --git a/icij-worker/icij_worker/worker/amqp.py b/icij-worker/icij_worker/worker/amqp.py
@@ -224,6 +224,7 @@ def _create_publisher(self) -> AMQPPublisher:
             broker_url=self._broker_url,
             connection_timeout_s=self._reconnection_wait_s,
             reconnection_wait_s=self._reconnection_wait_s,
+            is_qpid=self._is_qpid,
             app_id=self._app.name,
         )
 
@@ -235,8 +236,8 @@ def _from_config(cls, config: AMQPWorkerConfig, **extras) -> AMQPWorker:
             broker_url=config.broker_url,
             connection_timeout_s=config.connection_timeout_s,
             reconnection_wait_s=config.reconnection_wait_s,
-            inactive_after_s=config.inactive_after_s,
             is_qpid=config.rabbitmq_is_qpid,
+            inactive_after_s=config.inactive_after_s,
             **extras,
         )
         return worker