Merge pull request #751 from weni-ai/feature/adding-project-auth-message

wait to retry just when dont send message
weni-ai · Sep 22, 2023 · 435faee · 435faee
2 parents 622bc51 + 0bcd443
commit 435faee
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/connect/internals/event_driven/producer/rabbitmq_publisher.py b/connect/internals/event_driven/producer/rabbitmq_publisher.py
@@ -35,4 +35,5 @@ def send_message(self, body: Dict, exchange: str, routing_key: str):
             except Exception as err:
                 print(f"error: {err}")
                 self.rabbitmq_connection.make_connection()
-            sleep(settings.EDA_WAIT_TIME_RETRY)
+            if not sended:
+                sleep(settings.EDA_WAIT_TIME_RETRY)