MySmartHome/bt-mqtt-gateway
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Improve mqtt lwt on reconnect

Browse Source
This commit is contained in:
zewelor
2019-04-19 18:16:02 +02:00
parent 6561c2cb60
commit 074a7837d8
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
mqtt.py
+7 -3
View File
@@ -61,7 +61,14 @@ class MqttClient:
def mqttc(self): def mqttc(self):
return self._mqttc return self._mqttc
def on_connect(self, client, userdata, flags, rc):
if self.availability_topic:
self.publish([MqttMessage(topic=self.availability_topic, payload=LWT_ONLINE, retain=True)])
def callbacks_subscription(self, callbacks): def callbacks_subscription(self, callbacks):
self.mqttc.on_connect = self.on_connect
self.mqttc.connect(self.hostname, port=self.port) self.mqttc.connect(self.hostname, port=self.port)
for topic, callback in callbacks: for topic, callback in callbacks:
@@ -72,9 +79,6 @@ class MqttClient:
self.mqttc.loop_start() self.mqttc.loop_start()
if self.availability_topic:
self.publish([MqttMessage(topic=self.availability_topic, payload=LWT_ONLINE, retain=True)])
def __del__(self): def __del__(self):
if self.availability_topic: if self.availability_topic:
self.publish([MqttMessage(topic=self.availability_topic, payload=LWT_OFFLINE, retain=True)]) self.publish([MqttMessage(topic=self.availability_topic, payload=LWT_OFFLINE, retain=True)])