Skip to content

Commit 63a1ea7

Browse files
authored
Merge pull request #8085 from chaen/v8.0_fix_stompBrokenPipe
fix (MQ): catch ConnectionError upon send
2 parents d10afe5 + ddf2e44 commit 63a1ea7

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)