Fix mqtt prefix handling on thermostat worker (#30)

2018-11-28 15:52:52 +01:00
parent 7a3fedac36
commit a5a4797a1d
2 changed files with 5 additions and 1 deletions
@@ -59,6 +59,8 @@ class MqttClient:
    self.mqttc.connect(self.hostname, port=self.port)

    for topic, callback in callbacks:
+      if self.topic_prefix is not None:
+        topic = "{}/{}".format(self.topic_prefix, topic)
      self.mqttc.message_callback_add(topic, callback)
      self.mqttc.subscribe(topic)