From cd51f18eaba9694875334f146a3651a7a077582a Mon Sep 17 00:00:00 2001 From: Benjamin Dweck Date: Thu, 22 Oct 2020 10:50:24 +0200 Subject: [PATCH] Trying to fix disconnection issue using the paho-mqtt loop... --- torch_agent/torch_agent.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/torch_agent/torch_agent.py b/torch_agent/torch_agent.py index 415cbf5..831c185 100755 --- a/torch_agent/torch_agent.py +++ b/torch_agent/torch_agent.py @@ -32,7 +32,7 @@ def main(): config = configparser.ConfigParser() configuration_file_path = config_path + "torch.conf" - print("Reading configuration file at '%s'" % (configuration_file_path)) + print("Reading configuration file at '%s'" % configuration_file_path) config.read(configuration_file_path) tor_proxy_host = config['tor'].get('ProxyHost', fallback="127.0.0.1") @@ -76,12 +76,14 @@ def main(): print("Published payload!") pub_client.disconnect() - def on_disconnect(): + def on_disconnect(pub_client): print("Disconnected!") + pub_client.loop_stop() client = mqtt.Client() client.on_publish = on_publish client.on_disconnect = on_disconnect + client.loop_start() protocol = "mqtt"