diff --git a/neon_mq_connector/consumers/blocking_consumer.py b/neon_mq_connector/consumers/blocking_consumer.py
index d2dff79..a2aaa37 100644
--- 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()