Skip to content

Commit 2693a89

Browse files
committed
Updated message splitting for RPC and connect/disconnect requests
1 parent 7ca97e1 commit 2693a89

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

tb_device_mqtt.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -677,7 +677,9 @@ def __send_publish_with_limitations(self, kwargs, timeout, device=None, msg_rate
677677
"splitting to messages with %i datapoints",
678678
datapoints, dp_rate_limit.get_minimal_limit())
679679
if device is None or data.get(device) is None:
680-
split_messages = self._split_message(data, dp_rate_limit.get_minimal_limit())
680+
device_split_messages = self._split_message(data, dp_rate_limit.get_minimal_limit())
681+
split_messages = [{'message': split_message['data'], 'datapoints': split_message['datapoints']}
682+
for split_message in device_split_messages]
681683
else:
682684
device_data = data.get(device)
683685
device_split_messages = self._split_message(device_data, dp_rate_limit.get_minimal_limit())

0 commit comments

Comments
 (0)