add is_alive log message

cenkalti · Dec 5, 2023 · 8f299d5 · 8f299d5
1 parent 5fc9add
commit 8f299d5
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/kuyruk/connection.py b/kuyruk/connection.py
@@ -87,6 +87,7 @@ def _get(self) -> amqp.Connection:
             self._connection = self.new_connection()
 
         if not self._is_alive:
+            logger.error("RabbitMQ connection is not alive. New connection will be opened.")
             self._remove_connection(suppress_exceptions=True)
             self._connection = self.new_connection()