fix: Add wait timeout when connecting to stomp

Author: chrisburr

src/DIRAC/Resources/MessageQueue/StompMQConnector.py

@@ -200,10 +200,14 @@ def connect(self, parameters=None):
 
         for _ in range(10):
             try:
-                # We need to explicitely call disconnect to avoid leaving
-                # threads behind
+                # We need to explicitly call disconnect to avoid leaving threads behind
                 self.connection.disconnect()
-                self.connection.connect(username=user, passcode=password, wait=True)
+
+                # Connect to the broker with a timeout of 30 seconds
+                self.connection.connect(username=user, passcode=password, wait=False)
+                self.transport.wait_for_connection(30)  # pylint: disable=no-member
+                if self.transport.connection_error:  # pylint: disable=no-member
+                    raise stomp.exception.ConnectFailedException()
 
                 if self.connection.is_connected():
                     # Go to the socket of the Stomp to find the remote host