From c08437ec42c855440c76033f0b3958ec4259687b Mon Sep 17 00:00:00 2001 From: Marat Fayzullin Date: Thu, 23 May 2024 14:51:48 -0400 Subject: [PATCH 1/2] Fixedi failed MQTT connection blocking OWRX startup. --- owrx/reporting/mqtt.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/owrx/reporting/mqtt.py b/owrx/reporting/mqtt.py index edd55306..1d21e17e 100644 --- a/owrx/reporting/mqtt.py +++ b/owrx/reporting/mqtt.py @@ -40,7 +40,11 @@ class MqttReporter(Reporter): host = parts[0] if len(parts) > 1: port = int(parts[1]) - client.connect(host=host, port=port) + + 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() From cc74dcbe7fa629f5cb2abf163fd7e80ee4e9d734 Mon Sep 17 00:00:00 2001 From: "Luarvique L. Luarvique" Date: Thu, 23 May 2024 15:27:30 -0400 Subject: [PATCH 2/2] Update mqtt.py Changed to logger.exception() --- owrx/reporting/mqtt.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/owrx/reporting/mqtt.py b/owrx/reporting/mqtt.py index 1d21e17e..16ca75b0 100644 --- a/owrx/reporting/mqtt.py +++ b/owrx/reporting/mqtt.py @@ -43,8 +43,8 @@ class MqttReporter(Reporter): try: client.connect(host=host, port=port) - except Exception as e: - logger.debug("Exception connecting: " + str(e)) + except: + logger.exception("Exception connecting to MQTT server") threading.Thread(target=client.loop_forever).start()