possibly fixes rabbitmq bugs

synergylabs · Jan 23, 2024 · 7ac852a · 7ac852a
1 parent b2baf8d
commit 7ac852a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/buildingdepot/DataService/app/rest_api/helper.py b/buildingdepot/DataService/app/rest_api/helper.py
@@ -134,7 +134,7 @@ def connect_broker():
     """
     try:
         credentials = pika.PlainCredentials(rabbitmq_username, rabbitmq_password)
-        parameters = pika.ConnectionParameters(host="localhost", credentials=credentials)
+        parameters = pika.ConnectionParameters(host="localhost", credentials=credentials, connection_attempts=3, retry_delay=5)
         pubsub = pika.BlockingConnection(parameters)
         channel = pubsub.channel()
         channel.exchange_declare(exchange=exchange, exchange_type="direct")