RabbitMQ: Init queue on topic open

Flared · Nov 23, 2023 · 48c4496 · 48c4496
1 parent c06441e
commit 48c4496
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/saturn_engine/worker/topics/rabbitmq.py b/src/saturn_engine/worker/topics/rabbitmq.py
@@ -114,6 +114,9 @@ def __init__(self, options: Options, services: Services, **kwargs: object) -> No
             )
         self.queue_arguments.setdefault("x-overflow", self.options.overflow)
 
+    async def open(self) -> None:
+        await self.ensure_queue()
+
     async def run(self) -> AsyncGenerator[t.AsyncContextManager[TopicMessage], None]:
         if self.is_closed:
             raise TopicClosedError()