mirror of
https://github.com/alexhopeoconnor/SunGather.git
synced 2026-10-04 02:48:12 +10:00
fix MQTT publish error
This commit is contained in:
@@ -58,9 +58,11 @@ class export_mqtt(object):
|
|||||||
logging.info(f"MQTT: Server Disconnected code: {rc}")
|
logging.info(f"MQTT: Server Disconnected code: {rc}")
|
||||||
|
|
||||||
def on_publish(self, client, userdata, mid):
|
def on_publish(self, client, userdata, mid):
|
||||||
if mid:
|
try:
|
||||||
self.mqtt_queue.remove(mid)
|
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):
|
def cleanName(self, name):
|
||||||
return name.lower().replace(' ','_')
|
return name.lower().replace(' ','_')
|
||||||
|
|||||||
Reference in New Issue
Block a user