diff --git a/aprsd_weewx_plugin/conf/__init__.py b/aprsd_weewx_plugin/conf/__init__.py index 4a77677..becc967 100644 --- a/aprsd_weewx_plugin/conf/__init__.py +++ b/aprsd_weewx_plugin/conf/__init__.py @@ -1,10 +1,7 @@ -import logging - from oslo_config import cfg from aprsd_weewx_plugin.conf import weewx CONF = cfg.CONF - weewx.register_opts(CONF) diff --git a/aprsd_weewx_plugin/weewx.py b/aprsd_weewx_plugin/weewx.py index 272ad99..5cb23cc 100644 --- a/aprsd_weewx_plugin/weewx.py +++ b/aprsd_weewx_plugin/weewx.py @@ -168,6 +168,7 @@ class WeewxMQTTThread(threads.APRSDThread): _mqtt_host = None _mqtt_port = None client = None + def __init__(self, wx_queue, msg_queue): super().__init__("WeewxMQTTThread") self.msg_queue = msg_queue