From 73897bffa2ff2ba1c8b025c577b16be6b7653699 Mon Sep 17 00:00:00 2001 From: Tobias Brunner Date: Thu, 18 Jan 2018 23:14:26 +0100 Subject: [PATCH] fix mqtt logging --- library/mqtt.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/library/mqtt.py b/library/mqtt.py index ee3d0b2..12ff796 100644 --- a/library/mqtt.py +++ b/library/mqtt.py @@ -29,11 +29,10 @@ class MQTTClient: def send_message(self, f_type, f_id, pdf_data=None, pdf_file=None): """ Publish a message over MQTT """ - self.logger.info('[%s] Publishing information on MQTT topic %s*', f_id, topic) - if f_type == 'Einsatzausdruck_FW': try: topic = "{0}/Einsatzausdruck_FW/{1}/".format(self.base_topic, f_id) + self.logger.info('[%s] Publishing information on MQTT topic %s', f_id, topic) self.mqtt_client.publish(topic + 'json', json.dumps(pdf_data)) ## Publish the PDF blob @@ -44,4 +43,5 @@ class MQTTClient: self.logger.info('[%s] Cannot publish information: %s', f_id, err) elif f_type == 'Einsatzprotokoll': topic = "{0}/Einsatzprotokoll/{1}/".format(self.base_topic, f_id) + self.logger.info('[%s] Publishing information on MQTT topic %s', f_id, topic) self.mqtt_client.publish(topic + 'json', '{}')