fix MQTT publish error

bohdan-s · Jan 25, 2022 · 1b54ae3 · 1b54ae3
1 parent 9e7a926
commit 1b54ae3
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/SunGather/exports/mqtt.py b/SunGather/exports/mqtt.py
@@ -58,9 +58,11 @@ def on_disconnect(self, client, userdata, rc):
         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(' ','_')