debug
This commit is contained in:
@ -22,7 +22,7 @@ class MqttPublish(AbstractMqttPublisher):
|
|||||||
topic = self.topicPre + '/' + dataObject.getTopicPost()
|
topic = self.topicPre + '/' + dataObject.getTopicPost()
|
||||||
payload = dataObject.getPayload()
|
payload = dataObject.getPayload()
|
||||||
self.client.publish(topic, payload)
|
self.client.publish(topic, payload)
|
||||||
logger.info("mqtt message sent: {} -> {}".format(topic, payload))
|
logger.debug("mqtt message sent: {} -> {}".format(topic, payload))
|
||||||
except Empty:
|
except Empty:
|
||||||
if self.killBill:
|
if self.killBill:
|
||||||
logger.error("killbill received")
|
logger.error("killbill received")
|
||||||
|
Reference in New Issue
Block a user