jketterl/openwebrx
1
0
Fork 0
mirror of https://github.com/jketterl/openwebrx.git synced 2026-01-04 15:50:12 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

this works better for the loop

Browse source
This commit is contained in:
Jakob Ketterl 2024-01-31 03:29:01 +01:00
parent 2dc4f60e6b
commit 295874ebfc
1 changed files with 2 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
owrx/reporting/mqtt.py
View file

@ -22,8 +22,6 @@ class MqttReporter(Reporter):
pm.wireProperty("mqtt_topic", self._setTopic),
pm.filter("mqtt_host", "mqtt_user", "mqtt_password", "mqtt_client_id", "mqtt_use_ssl").wire(self._reconnect)
]
self.run = True
threading.Thread(target=self._loop).start()
def _getClient(self):
pm = Config.get()
@ -44,13 +42,9 @@ class MqttReporter(Reporter):
port = int(parts[1])
client.connect(host=host, port=port)
return client
threading.Thread(target=client.loop_forever).start()
def _loop(self):
# basic keepalive loop
while self.run:
self.client.loop()
time.sleep(5)
return client
def _setTopic(self, topic):
if topic is PropertyDeleted:
@ -64,7 +58,6 @@ class MqttReporter(Reporter):
old.disconnect()
def stop(self):
self.run = False
self.client.disconnect()
while self.subscriptions:
self.subscriptions.pop().cancel()