From 3f13fbd23f3df2679fb604ec7fbb391a4f6c511e Mon Sep 17 00:00:00 2001
From: dashevchenko <dshevchenko@thingsboard.io>
Date: Wed, 26 Mar 2025 13:24:49 +0200
Subject: [PATCH] fixed telemetry update handling for all keys

---
 .../DefaultTbLocalSubscriptionService.java    | 27 ++++++++++++++-----
 1 file changed, 21 insertions(+), 6 deletions(-)

diff --git a/application/src/main/java/org/thingsboard/server/service/subscription/DefaultTbLocalSubscriptionService.java b/application/src/main/java/org/thingsboard/server/service/subscription/DefaultTbLocalSubscriptionService.java
index 165b0824f5..627b7f8b63 100644
--- a/application/src/main/java/org/thingsboard/server/service/subscription/DefaultTbLocalSubscriptionService.java
+++ b/application/src/main/java/org/thingsboard/server/service/subscription/DefaultTbLocalSubscriptionService.java
@@ -343,13 +343,28 @@ public class DefaultTbLocalSubscriptionService implements TbLocalSubscriptionSer
                 s -> {
                     TbTimeSeriesSubscription sub = (TbTimeSeriesSubscription) s;
                     List<TsKvEntry> updateData = null;
-                    for (TsKvEntry kv : data) {
-                        if (sub.getKeyStates().containsKey((kv.getKey()))) {
-                            if (!sub.isLatestValues() || kv.getTs() > sub.getKeyStates().get(kv.getKey())) {
-                                if (updateData == null) {
-                                    updateData = new ArrayList<>();
+                    if (sub.isAllKeys()) {
+                        if (sub.isLatestValues()) {
+                            for (TsKvEntry kv : data) {
+                                if (!sub.getKeyStates().containsKey((kv.getKey())) || kv.getTs() > sub.getKeyStates().get(kv.getKey())) {
+                                    if (updateData == null) {
+                                        updateData = new ArrayList<>();
+                                    }
+                                    updateData.add(kv);
+                                }
+                            }
+                        } else {
+                            updateData = data;
+                        }
+                    } else {
+                        for (TsKvEntry kv : data) {
+                            if (sub.getKeyStates().containsKey((kv.getKey()))) {
+                                if (!sub.isLatestValues() || kv.getTs() > sub.getKeyStates().get(kv.getKey())) {
+                                    if (updateData == null) {
+                                        updateData = new ArrayList<>();
+                                    }
+                                    updateData.add(kv);
                                 }
-                                updateData.add(kv);
                             }
                         }
                     }