Merge pull request #80 from samson0v/master

Fixed processing attribute requests
thingsboard · Oct 30, 2024 · 2a19f1a · 2a19f1a
2 parents 256e5b9 + 685d78a
commit 2a19f1a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/tb_device_mqtt.py b/tb_device_mqtt.py
@@ -1225,6 +1225,9 @@ def _split_message(message_pack, datapoints_max_count, max_payload_size):
 
         return split_messages
 
+    def add_attrs_request_timeout(self, attr_request_number, timeout):
+        self.__attrs_request_timeout[attr_request_number] = timeout
+
 
 class ProvisionClient(paho.Client):
     PROVISION_REQUEST_TOPIC = "/provision/request"

diff --git a/tb_gateway_mqtt.py b/tb_gateway_mqtt.py
@@ -175,7 +175,7 @@ def __request_attributes(self, device, keys, callback, type_is_client=False):
                "id": attr_request_number}
         info = self._send_device_request(TBSendMethod.PUBLISH, device, topic=GATEWAY_ATTRIBUTES_REQUEST_TOPIC, data=msg,
                                          qos=1)
-        self.__attrs_request_timeout[attr_request_number] = int(time()) + 20
+        self.add_attrs_request_timeout(attr_request_number, int(time()) + 20)
         return info
 
     def _send_device_request(self, _type, device_name, **kwargs):