From 6a0f94a982f6ac5abb93fc06b4e12455f9196fdd Mon Sep 17 00:00:00 2001 From: Yusuf Ali Date: Wed, 12 Mar 2025 23:51:44 -0400 Subject: [PATCH] fix(rabbitmq): bring ioloop earlier --- servc/svc/com/bus/rabbitmq.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/servc/svc/com/bus/rabbitmq.py b/servc/svc/com/bus/rabbitmq.py index df51212..2727780 100644 --- a/servc/svc/com/bus/rabbitmq.py +++ b/servc/svc/com/bus/rabbitmq.py @@ -64,6 +64,7 @@ def _connect( on_open_callback=lambda _c: self.get_channel(method, args), on_close_callback=self.on_connection_closed, ) + self._conn.ioloop.run_forever() # type: ignore def _close(self, expected=True, reason: Any = None): print("Close method called", flush=True) @@ -193,7 +194,6 @@ def subscribe( # type: ignore (route, inputProcessor, onConsuming, bindEventExchange), blocking=False, ) - self._conn.ioloop.run_forever() # type: ignore elif self.isBlockingConnection(): self.close() return self.subscribe(route, inputProcessor, onConsuming, bindEventExchange)