fix (StompMQConnector): add a timeout for the StompConnector

src/DIRAC/Resources/MessageQueue/StompMQConnector.py

@@ -35,6 +35,7 @@ class StompMQConnector(MQConnector):
     RECONNECT_SLEEP_MAX = 120  # [s] The maximum delay that can be reached independent of increasing procedure.
     RECONNECT_SLEEP_JITTER = 0.1  # Random factor to add. 0.1 means a random number from 0 to 10% of the current time.
     RECONNECT_ATTEMPTS_MAX = 1e4  # Maximum attempts to reconnect.
+    STOMP_TIMEOUT = 60
 
     PORT = 61613
 
@@ -72,6 +73,8 @@ def setupConnection(self, parameters=None):
         reconnectSleepJitter = self.parameters.get("ReconnectSleepJitter", StompMQConnector.RECONNECT_SLEEP_JITTER)
         reconnectAttemptsMax = self.parameters.get("ReconnectAttemptsMax", StompMQConnector.RECONNECT_ATTEMPTS_MAX)
 
+        stompTimeout = self.parameters.get("Timeout", StompMQConnector.STOMP_TIMEOUT)
+
         host = self.parameters.get("Host")
         port = self.parameters.get("Port", StompMQConnector.PORT)
         vhost = self.parameters.get("VHost")
@@ -83,6 +86,7 @@ def setupConnection(self, parameters=None):
         connectionArgs = {
             "vhost": vhost,
             "keepalive": True,
+            "timeout": stompTimeout,
             "reconnect_sleep_initial": reconnectSleepInitial,
             "reconnect_sleep_increase": reconnectSleepIncrease,
             "reconnect_sleep_max": reconnectSleepMax,