zuul
/
zuul
Code Issues Proposed changes

Merge "Ensure correct state in MQTT connection"

This commit is contained in:
Zuul 2019-05-16 20:57:43 +00:00 committed by Gerrit Code Review
parent 1901296239 e128bead15
commit 2a53810318
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
zuul/driver/mqtt/mqttconnection.py
View File

@ -52,6 +52,14 @@ class MQTTConnection(BaseConnection):
keyfile=keyfile,
ciphers=ciphers)
self.connected = False
self.client.on_connect = self._on_connect
self.client.on_disconnect = self._on_disconnect
def _on_connect(self, client, userdata, flags, rc):
self.connected = True
def _on_disconnect(self, client, userdata, rc):
self.connected = False
def onLoad(self):
self.log.debug("Starting MQTT Connection")