update timings

worker.py

@@ -24,8 +24,8 @@ class RabbitMQWorker:
     def setup_publisher(self):
         if not self.publisher_connection or self.publisher_connection.is_closed:
             connection_params = pika.URLParameters(self.rabbit_url)
-            connection_params.heartbeat = 5  # Match the consumer heartbeat
-            connection_params.blocked_connection_timeout = 2  # Increase timeout
+            connection_params.heartbeat = 1000 # Match the consumer heartbeat
+            connection_params.blocked_connection_timeout = 500  # Increase timeout
             
             self.publisher_connection = pika.BlockingConnection(connection_params)
             self.publisher_channel = self.publisher_connection.channel()
@@ -111,8 +111,8 @@ class RabbitMQWorker:
     def connect_to_rabbitmq(self):
         """Establish connection to RabbitMQ with heartbeat"""
         connection_params = pika.URLParameters(self.rabbit_url)
-        connection_params.heartbeat = 5
-        connection_params.blocked_connection_timeout = 2
+        connection_params.heartbeat = 1000
+        connection_params.blocked_connection_timeout = 500
         
         connection = pika.BlockingConnection(connection_params)
         channel = connection.channel()