From 73d39f40720c038f290174dcb4820f7a5c20db77 Mon Sep 17 00:00:00 2001 From: Andrii Shvaika Date: Mon, 9 Aug 2021 16:02:07 +0300 Subject: [PATCH] Fixed logging of the device state service partitions --- .../server/service/state/DefaultDeviceStateService.java | 8 +++++--- 1 file changed, 5 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 bc322fe04d..ff85053ff8 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 @@ -348,9 +348,11 @@ public class DefaultDeviceStateService extends TbApplicationEventListener { - log.info("[{}]: {} devices", tpi.getFullTopicName(), devices.size()); + scheduledExecutor.submit(() -> { + log.info("Managing following partitions:"); + partitionedDevices.forEach((tpi, devices) -> { + log.info("[{}]: {} devices", tpi.getFullTopicName(), devices.size()); + }); }); } catch (Throwable t) { log.warn("Failed to init device states from DB", t);