LITE-26790 RMQ Connection is cleaned in any error case

cloudblue · Mar 20, 2023 · bf5c760 · bf5c760
1 parent 65d01a7
commit bf5c760
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/dj_cqrs/transport/rabbit_mq.py b/dj_cqrs/transport/rabbit_mq.py
@@ -114,10 +114,12 @@ def _produce_with_retries(cls, payload, retries):
             exceptions.ReentrancyError,
             AMQPConnectorException,
         ) as e:
+            # in case of any error - close connection and try to reconnect
+            cls.clean_connection()
+
             base_log_message = "CQRS couldn't be published: pk = {0} ({1}).".format(
                 payload.pk, payload.cqrs_id,
             )
-
             if not retries:
                 logger.exception(base_log_message)
                 return
@@ -126,8 +128,6 @@ def _produce_with_retries(cls, payload, retries):
                 base_log_message, e.__class__.__name__,
             ))
 
-            # in case of any error - close connection and try to reconnect
-            cls.clean_connection()
             cls._produce_with_retries(payload, retries - 1)
 
     @classmethod