Ignore StreamLostErrors during consumer shutdown

NeonGeckoCom · Jan 2, 2025 · 3896d64 · 3896d64
1 parent 89c0e26
commit 3896d64
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/neon_mq_connector/consumers/blocking_consumer.py b/neon_mq_connector/consumers/blocking_consumer.py
@@ -114,6 +114,9 @@ def run(self):
                 if self._is_consumer_alive:
                     self._close_connection()
                     self.error_func(self, e)
+            except pika.exceptions.StreamLostError as e:
+                if self._is_consumer_alive:
+                    self.error_func(self, e)
             except Exception as e:
                 if self._is_consumer_alive:
                     self._close_connection()