From 73afd9a7f4e6190f1cc430a36af3c369e15dd8a3 Mon Sep 17 00:00:00 2001 From: Dmytro Skarzhynets Date: Thu, 15 Feb 2024 18:55:12 +0200 Subject: [PATCH] Make device state manage a rule engine component --- .../java/org/thingsboard/server/actors/ActorSystemContext.java | 2 +- .../service/state/DefaultRuleEngineDeviceStateManager.java | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/application/src/main/java/org/thingsboard/server/actors/ActorSystemContext.java b/application/src/main/java/org/thingsboard/server/actors/ActorSystemContext.java index 2a4f132be8..e3ebbdf892 100644 --- a/application/src/main/java/org/thingsboard/server/actors/ActorSystemContext.java +++ b/application/src/main/java/org/thingsboard/server/actors/ActorSystemContext.java @@ -204,7 +204,7 @@ public class ActorSystemContext { @Getter private DeviceCredentialsService deviceCredentialsService; - @Autowired + @Autowired(required = false) @Getter private RuleEngineDeviceStateManager deviceStateManager; diff --git a/application/src/main/java/org/thingsboard/server/service/state/DefaultRuleEngineDeviceStateManager.java b/application/src/main/java/org/thingsboard/server/service/state/DefaultRuleEngineDeviceStateManager.java index 722fcd1aac..af2b03ec8f 100644 --- a/application/src/main/java/org/thingsboard/server/service/state/DefaultRuleEngineDeviceStateManager.java +++ b/application/src/main/java/org/thingsboard/server/service/state/DefaultRuleEngineDeviceStateManager.java @@ -29,12 +29,14 @@ import org.thingsboard.server.gen.transport.TransportProtos; import org.thingsboard.server.queue.common.SimpleTbQueueCallback; import org.thingsboard.server.queue.discovery.PartitionService; import org.thingsboard.server.queue.discovery.TbServiceInfoProvider; +import org.thingsboard.server.queue.util.TbRuleEngineComponent; import java.util.Optional; import java.util.UUID; @Slf4j @Service +@TbRuleEngineComponent public class DefaultRuleEngineDeviceStateManager implements RuleEngineDeviceStateManager { private final TbServiceInfoProvider serviceInfoProvider;