mirror/thingsboard-gateway
1
0
Fork 0
mirror of https://github.com/thingsboard/thingsboard-gateway synced 2025-10-26 22:31:42 +08:00
Code Issues Releases Wiki Activity

Fixed TB Gateway Service reconnect

Browse Source
This commit is contained in:
samson0v
2023-03-14 16:31:21 +02:00
parent 83ce43b1fe
commit 93b77279e0
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
thingsboard_gateway/gateway/tb_gateway_service.py
View File

@@ -339,7 +339,7 @@ class TBGatewayService:
if self.tb_client.is_connected() and not self.__subscribed_to_rpc_topics:
for device in self.__saved_devices:
self.add_device(device, {"connector": self.__saved_devices[device]["connector"]},
device_type=self.__saved_devices[device]["device_type"])
device_type=self.__saved_devices[device]["device_type"], reconnect=True)
self.subscribe_to_required_topics()
self.__subscribed_to_rpc_topics = True
@@ -1189,8 +1189,8 @@ class TBGatewayService:
else:
return Status.FAILURE
def add_device(self, device_name, content, device_type=None):
if device_name not in self.__saved_devices:
def add_device(self, device_name, content, device_type=None, reconnect=False):
if device_name not in self.__saved_devices or reconnect:
device_type = device_type if device_type is not None else 'default'
self.__connected_devices[device_name] = {**content, "device_type": device_type}
self.__saved_devices[device_name] = {**content, "device_type": device_type}