Fixedi failed MQTT connection blocking OWRX startup.

This commit is contained in:
Marat Fayzullin 2024-05-23 14:51:48 -04:00
parent 10c642e102
commit c08437ec42

View file

@ -40,7 +40,11 @@ class MqttReporter(Reporter):
host = parts[0]
if len(parts) > 1:
port = int(parts[1])
try:
client.connect(host=host, port=port)
except Exception as e:
logger.debug("Exception connecting: " + str(e))
threading.Thread(target=client.loop_forever).start()
@ -53,6 +57,7 @@ class MqttReporter(Reporter):
self.topic = topic
def _reconnect(self, *args, **kwargs):
logger.debug("Reconnecting...")
old = self.client
self.client = self._getClient()
old.disconnect()