Skip to content

Commit ddf2e44

Browse files
committed
fix (MQ): catch ConnectionError upon send
1 parent d10afe5 commit ddf2e44

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

src/DIRAC/Resources/MessageQueue/StompMQConnector.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -175,7 +175,7 @@ def put(self, message, parameters=None):
175175
try:
176176
try:
177177
self.connection.send(body=json.dumps(message), destination=destination)
178-
except stomp.exception.StompException:
178+
except (stomp.exception.StompException, ConnectionError):
179179
self.connect()
180180
self.connection.send(body=json.dumps(message), destination=destination)
181181
except Exception as e:

0 commit comments

Comments
 (0)