Run listen_topic in a thread

HSLdevcom · Sep 5, 2022 · 9ccd65e · 9ccd65e
1 parent 514fd09
commit 9ccd65e
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/mqtt_data_collector.py b/mqtt_data_collector.py
@@ -110,7 +110,12 @@ def main():
         for topic in topic_list:
             if topic.is_running == False:
                 print(f"Topic {topic.topic_name} was not running, starting it.")
-                topic.listen_topic()
+
+                # Run listen_topic in a thread because we don't want to wait e.g. client.connect() etc.
+                # If we didn't use threads here, one connection being stuck could cause long
+                # timeout for sending data to Azure.
+                t = Thread(target=topic.listen_topic)
+                t.start()
 
         sleep_time = time_end - time.time()
         print(sleep_time)