From 03f0f3d646b6e87be700ea04d6032a921e2a2b70 Mon Sep 17 00:00:00 2001 From: Lukas Holecek Date: Apr 14 2021 08:29:57 +0000 Subject: Fix disconnecting messaging socket using stomp Avoids issue: https://github.com/jasonrbriggs/stomp.py/issues/323 --- diff --git a/resultsdb/messaging.py b/resultsdb/messaging.py index 2ae7a43..bb27093 100644 --- a/resultsdb/messaging.py +++ b/resultsdb/messaging.py @@ -191,7 +191,7 @@ class StompPlugin(MessagingPlugin): kwargs['message'] = kwargs.pop('body') # On EL7, different sig. conn = self.stomp.Connection(**self.connection) - conn.connect() + conn.connect(wait=True) try: conn.send(**kwargs) log.debug("Published message through stomp: %s", msg)