diff options
author | Evgeny Zinoviev <me@ch1p.io> | 2023-05-11 04:18:08 +0300 |
---|---|---|
committer | Evgeny Zinoviev <me@ch1p.io> | 2023-05-11 04:18:12 +0300 |
commit | 0aba139aeff8ff80757c5d36502413299a0b449e (patch) | |
tree | 2b8e760ff14d4691783eb7c7d341f093199aab82 /src/polaris_kettle_util.py | |
parent | 586d84b0c0a8b4dc1b5057733892b754397234ec (diff) |
mqtt, esp: add new esp8266-based device
Diffstat (limited to 'src/polaris_kettle_util.py')
-rwxr-xr-x | src/polaris_kettle_util.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/polaris_kettle_util.py b/src/polaris_kettle_util.py index 61c1c7d..81326dd 100755 --- a/src/polaris_kettle_util.py +++ b/src/polaris_kettle_util.py @@ -8,7 +8,7 @@ import paho.mqtt.client as mqtt from typing import Optional from argparse import ArgumentParser from queue import SimpleQueue -from home.mqtt import MQTTBase +from home.mqtt import MqttBase from home.config import config from syncleo import ( Kettle, @@ -21,7 +21,7 @@ logger = logging.getLogger(__name__) control_tasks = SimpleQueue() -class MQTTServer(MQTTBase): +class MqttServer(MqttBase): def __init__(self): super().__init__(clean_session=False) @@ -78,7 +78,7 @@ def main(): arg = config.load('polaris_kettle_util', use_cli=True, parser=parser) if arg.mode == 'mqtt': - server = MQTTServer() + server = MqttServer() try: server.connect_and_loop(loop_forever=True) except KeyboardInterrupt: |