From ed312b91fb818852b5f85dd69d90d2a8b3a38810 Mon Sep 17 00:00:00 2001 From: Tobias Brunner Date: Thu, 18 Jan 2018 22:45:14 +0100 Subject: [PATCH] mqtt topics update for client compat --- library/mqtt.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/library/mqtt.py b/library/mqtt.py index 7d0459a..ee3d0b2 100644 --- a/library/mqtt.py +++ b/library/mqtt.py @@ -29,12 +29,11 @@ class MQTTClient: def send_message(self, f_type, f_id, pdf_data=None, pdf_file=None): """ Publish a message over MQTT """ - topic = "{0}/{1}/".format(self.base_topic, f_id) self.logger.info('[%s] Publishing information on MQTT topic %s*', f_id, topic) if f_type == 'Einsatzausdruck_FW': try: - self.mqtt_client.publish(topic + 'typ', 'Einsatzauftrag') + topic = "{0}/Einsatzausdruck_FW/{1}/".format(self.base_topic, f_id) self.mqtt_client.publish(topic + 'json', json.dumps(pdf_data)) ## Publish the PDF blob @@ -44,4 +43,5 @@ class MQTTClient: except IndexError as err: self.logger.info('[%s] Cannot publish information: %s', f_id, err) elif f_type == 'Einsatzprotokoll': - self.mqtt_client.publish(topic + 'typ', 'Einsatzprotokoll') + topic = "{0}/Einsatzprotokoll/{1}/".format(self.base_topic, f_id) + self.mqtt_client.publish(topic + 'json', '{}')