fix log messages

This commit is contained in:
Evgeny Zinoviev 2022-12-25 03:10:33 +03:00
parent 7bc380d970
commit cd7e5c16f3
2 changed files with 2 additions and 2 deletions

View File

@ -16,7 +16,7 @@ class MQTTReceiver(MQTTBase):
def on_connect(self, client: mqtt.Client, userdata, flags, rc): def on_connect(self, client: mqtt.Client, userdata, flags, rc):
super().on_connect(client, userdata, flags, rc) super().on_connect(client, userdata, flags, rc)
self._logger.info("subscribing to home/#") self._logger.info("subscribing to hk/#")
client.subscribe('hk/#', qos=1) client.subscribe('hk/#', qos=1)
def on_message(self, client: mqtt.Client, userdata, msg): def on_message(self, client: mqtt.Client, userdata, msg):

View File

@ -23,7 +23,7 @@ class MQTTServer(MQTTBase):
def on_connect(self, client: mqtt.Client, userdata, flags, rc): def on_connect(self, client: mqtt.Client, userdata, flags, rc):
super().on_connect(client, userdata, flags, rc) super().on_connect(client, userdata, flags, rc)
self._logger.info("subscribing to home/#") self._logger.info("subscribing to hk/#")
client.subscribe('hk/#', qos=1) client.subscribe('hk/#', qos=1)
def on_message(self, client: mqtt.Client, userdata, msg): def on_message(self, client: mqtt.Client, userdata, msg):