From ff54d190c924cff729dc1371044cb235b38a1d8a Mon Sep 17 00:00:00 2001 From: Sergey Matvienko Date: Fri, 14 May 2021 18:45:02 +0300 Subject: [PATCH] state service: refactored --- .../server/service/state/DefaultDeviceStateService.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/application/src/main/java/org/thingsboard/server/service/state/DefaultDeviceStateService.java b/application/src/main/java/org/thingsboard/server/service/state/DefaultDeviceStateService.java index 271dc11e67..ca8a731b65 100644 --- a/application/src/main/java/org/thingsboard/server/service/state/DefaultDeviceStateService.java +++ b/application/src/main/java/org/thingsboard/server/service/state/DefaultDeviceStateService.java @@ -367,7 +367,7 @@ public class DefaultDeviceStateService extends TbApplicationEventListener partitionedDevices.computeIfAbsent(tpi, key -> ConcurrentHashMap.newKeySet())); - initDeviceStatesForPartitions(addedPartitions); + initPartitions(addedPartitions); log.info("Managing following partitions:"); partitionedDevices.forEach((tpi, devices) -> { @@ -379,8 +379,8 @@ public class DefaultDeviceStateService extends TbApplicationEventListener addedPartitions) { + //Adding only entities that are in new partitions + boolean initPartitions(Set addedPartitions) { if (addedPartitions.isEmpty()) { return false; }