Ensure ioloops defined in run are started

NeonGeckoCom · Jan 16, 2025 · f01d50a · f01d50a
1 parent 2ef70bb
commit f01d50a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/neon_mq_connector/consumers/select_consumer.py b/neon_mq_connector/consumers/select_consumer.py
@@ -218,7 +218,9 @@ def run(self):
             get_event_loop()
         except RuntimeError as e:
             LOG.warning(e)
-            set_event_loop(new_event_loop())
+            loop = new_event_loop()
+            set_event_loop(loop)
+            loop.run_forever()
         if not self.is_consuming:
             try:
                 self.connection: pika.SelectConnection = self.create_connection()