add status message on mqtt
This commit is contained in:
@ -28,7 +28,7 @@ class MqttPublish(AbstractMqttPublisher):
|
|||||||
self.client.publish(topic, payload)
|
self.client.publish(topic, payload)
|
||||||
cnt += 1
|
cnt += 1
|
||||||
logger.debug("mqtt message sent: {} -> {}".format(topic, payload))
|
logger.debug("mqtt message sent: {} -> {}".format(topic, payload))
|
||||||
if cnt % 100 == 0:
|
if cnt % 100 == 1:
|
||||||
payload = { "count": cnt }
|
payload = { "count": cnt }
|
||||||
self.client.publish(self.statusTopic, json.dumps(payload), retain=True)
|
self.client.publish(self.statusTopic, json.dumps(payload), retain=True)
|
||||||
except Empty:
|
except Empty:
|
||||||
|
Reference in New Issue
Block a user