-
Notifications
You must be signed in to change notification settings - Fork 176
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[v8.0] fix (StompMQConnector): add a timeout for the StompConnector #7854
Conversation
@@ -83,6 +86,7 @@ def setupConnection(self, parameters=None): | |||
connectionArgs = { | |||
"vhost": vhost, | |||
"keepalive": True, | |||
"timeout": stompTimeout, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Having tried it we also need something like "heartbeats": (outgoingHeartbeatMs, incomingHeartbeatMs),
here as well. 15_000
seems like a sensible default
I think the logic also needs fixing to close the connection if it's still open. |
It doesn't close by itself on timeout? |
I wouldn't expect it to. |
After more consideration I don't think it's needed. |
Sweep summary Sweep ran in https://github.com/DIRACGrid/DIRAC/actions/runs/11551913575 Successful:
|
cc @chrisburr
for #7851
BEGINRELEASENOTES
*StompMQConnector
FIX: add a timeout for the StompConnector to handle nonresponsive sockets which can cause logging to be blocked
ENDRELEASENOTES