From 1b54ae3a708e10478fea6f1270153df6c093bfa5 Mon Sep 17 00:00:00 2001 From: bohdan-s Date: Tue, 25 Jan 2022 12:48:43 +1100 Subject: [PATCH] fix MQTT publish error --- SunGather/exports/mqtt.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/SunGather/exports/mqtt.py b/SunGather/exports/mqtt.py index 18b106a..d756c3d 100644 --- a/SunGather/exports/mqtt.py +++ b/SunGather/exports/mqtt.py @@ -58,9 +58,11 @@ class export_mqtt(object): logging.info(f"MQTT: Server Disconnected code: {rc}") def on_publish(self, client, userdata, mid): - if mid: + try: self.mqtt_queue.remove(mid) - logging.info(f"MQTT: Message {mid} Published") + except Exception as err: + pass + logging.info(f"MQTT: Message {mid} Published") def cleanName(self, name): return name.lower().replace(' ','_')