Added check is client connected, such as client can be disconnected i…

…n wrong way
thingsboard · Mar 13, 2024 · 63f947c · 63f947c
1 parent c3a94e2
commit 63f947c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/setup.py b/setup.py
@@ -21,7 +21,7 @@
 with open(path.join(this_directory, 'README.md')) as f:
     long_description = f.read()
 
-VERSION = "1.8.5"
+VERSION = "1.8.6"
 
 setup(
     version=VERSION,

diff --git a/tb_device_mqtt.py b/tb_device_mqtt.py
@@ -619,6 +619,8 @@ def set_server_side_rpc_request_handler(self, handler):
     def __sending_thread_main(self):
         while not self.stopped:
             if not self.is_connected():
+                if self._client._state == paho.mqtt_cs_connected:
+                    self._on_connect(self._client, None, None, 0)
                 time.sleep(0.1)
                 continue
             if not self.__rate_limit.check_limit_reached():