diff --git a/main/lib/idds/agents/common/plugins/messaging.py b/main/lib/idds/agents/common/plugins/messaging.py index 063167de..241bf67c 100644 --- a/main/lib/idds/agents/common/plugins/messaging.py +++ b/main/lib/idds/agents/common/plugins/messaging.py @@ -149,7 +149,7 @@ def connect_to_messaging_brokers(self, sender=True): for broker, port in broker_addresses: conn = stomp.Connection12(host_and_ports=[(broker, port)], keepalive=True, - heartbeats=(60000, 0), # one minute + heartbeats=(30000, 0), # one minute timeout=timeout) conns.append(conn) channel_conns[name] = conns