From 163793b25fe14c3550764fe71733b3d27b2b41ff Mon Sep 17 00:00:00 2001 From: Wen Guan Date: Fri, 15 Sep 2023 00:49:12 +0200 Subject: [PATCH] update heartbeat to 30 seconds --- main/lib/idds/agents/common/plugins/messaging.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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