Merge pull request #227 from kpfleming/fix-reconnection

Detect disconnections during poll() calls
TD22057 · Dec 11, 2020 · cb6726c · cb6726c
2 parents 774f348 + 292db9d
commit cb6726c
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/insteon_mqtt/network/Mqtt.py b/insteon_mqtt/network/Mqtt.py
@@ -179,8 +179,10 @@ def poll(self, t):
             passed in so that all clients receive the same "current" time
             instead of each calling time.time() and getting a different value.
         """
-        # This is required to handle keepalive messages.
-        self.client.loop_misc()
+        # This is required to handle keepalive messages and detect disconnections.
+        rc = self.client.loop_misc()
+        if rc == paho.MQTT_ERR_NO_CONN:
+            self._on_disconnect(self.client, None, rc)
 
     #-----------------------------------------------------------------------
     def retry_connect_dt(self):