Merge pull request #12 from netz39/10-mqtt-internal-reconnect

Use paho-mqtt reconnect feature instead of explicit call

Author: penguineer

src/SpaceStatusObserver.py

@@ -9,6 +9,7 @@ def __init__(self, broker, port, topic_status, topic_lastchange, space_api_entry
         self.space_api_entry = space_api_entry
 
         self.client = mqtt.Client()
+        self.client.reconnect_on_failure = True
         self.client.on_connect = self.on_connect
         self.client.on_disconnect = self.on_disconnect
         self.client.on_message = self.on_message
@@ -19,11 +20,10 @@ def on_connect(self, client, _userdata, _flags, rc):
             print(f"Subscribing to topic {topic}")
             client.subscribe(topic)
 
-    def on_disconnect(self, client, userdata, rc):
+    @staticmethod
+    def on_disconnect(_client, _userdata, rc):
         print(f"Disconnected with result code {rc}")
-        if rc != 0:
-            print("Unexpected disconnection. Reconnecting...")
-            self.client.reconnect()
+        # Reconnect is issued automatically by the client due to reconnect_on_failure=True
 
     def on_message(self, client, userdata, msg):
         print(f"Message received on topic {msg.topic}: {msg.payload.decode()}")