diff --git a/Dockerfile b/Dockerfile index 60de5ae..2e8220f 100644 --- a/Dockerfile +++ b/Dockerfile @@ -39,7 +39,7 @@ COPY elastalert_modules/ /opt/elastalert/elastalert_modules COPY patches/loaders.py /opt/elastalert/elastalert/loaders.py # Fix until https://github.com/Yelp/elastalert/pull/2640 is merged COPY patches/zabbix.py /opt/elastalert/elastalert/zabbix.py -# Fix until https://github.com/Yelp/elastalert/pull/2793 is merged +# Fix until https://github.com/Yelp/elastalert/pull/2793 and https://github.com/Yelp/elastalert/pull/3024 is merged COPY patches/alerts.py /opt/elastalert/elastalert/alerts.py # Add default rules directory diff --git a/patches/alerts.py b/patches/alerts.py index 4c0e47f..8af3c0a 100644 --- a/patches/alerts.py +++ b/patches/alerts.py @@ -371,7 +371,6 @@ def alert(self, matches): conn = stomp.Connection([(self.stomp_hostname, self.stomp_hostport)], use_ssl=self.stomp_ssl) - conn.start() conn.connect(self.stomp_login, self.stomp_password) # Ensures that the CONNECTED frame is received otherwise, the disconnect call will fail. time.sleep(1)