Add @TbCoreComponent and @TbTransportComponent

application/src/main/java/org/thingsboard/server/service/integration/activity/AllIntegrationActivityManager.java

@@ -42,6 +42,7 @@ import org.springframework.stereotype.Component;
 import org.thingsboard.server.common.transport.activity.AbstractActivityManager;
 import org.thingsboard.server.common.transport.activity.ActivityReportCallback;
 import org.thingsboard.server.common.transport.activity.ActivityState;
+import org.thingsboard.server.queue.util.TbCoreComponent;
 
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
@@ -50,6 +51,7 @@ import java.util.function.Supplier;
 
 @Slf4j
 @Component
+@TbCoreComponent
 @ConditionalOnProperty(prefix = "integrations.activity", value = "reporting_strategy", havingValue = "all")
 public class AllIntegrationActivityManager extends AbstractActivityManager<IntegrationActivityKey, ActivityState> {
 

application/src/main/java/org/thingsboard/server/service/integration/activity/FirstAndLastIntegrationActivityManager.java

@@ -43,6 +43,7 @@ import org.springframework.stereotype.Component;
 import org.thingsboard.server.common.transport.activity.AbstractActivityManager;
 import org.thingsboard.server.common.transport.activity.ActivityReportCallback;
 import org.thingsboard.server.common.transport.activity.ActivityState;
+import org.thingsboard.server.queue.util.TbCoreComponent;
 
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
@@ -51,6 +52,7 @@ import java.util.function.Supplier;
 
 @Slf4j
 @Component
+@TbCoreComponent
 @ConditionalOnProperty(prefix = "integrations.activity", value = "reporting_strategy", havingValue = "first-and-last")
 public class FirstAndLastIntegrationActivityManager extends AbstractActivityManager<IntegrationActivityKey, ActivityState> {
 

application/src/main/java/org/thingsboard/server/service/integration/activity/FirstOnlyIntegrationActivityManager.java

@@ -43,6 +43,7 @@ import org.springframework.stereotype.Component;
 import org.thingsboard.server.common.transport.activity.AbstractActivityManager;
 import org.thingsboard.server.common.transport.activity.ActivityReportCallback;
 import org.thingsboard.server.common.transport.activity.ActivityState;
+import org.thingsboard.server.queue.util.TbCoreComponent;
 
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
@@ -51,6 +52,7 @@ import java.util.function.Supplier;
 
 @Slf4j
 @Component
+@TbCoreComponent
 @ConditionalOnProperty(prefix = "integrations.activity", value = "reporting_strategy", havingValue = "first")
 public class FirstOnlyIntegrationActivityManager extends AbstractActivityManager<IntegrationActivityKey, ActivityState> {
 

application/src/main/java/org/thingsboard/server/service/integration/activity/LastOnlyIntegrationActivityManager.java

@@ -36,6 +36,7 @@ import org.springframework.stereotype.Component;
 import org.thingsboard.server.common.transport.activity.AbstractActivityManager;
 import org.thingsboard.server.common.transport.activity.ActivityReportCallback;
 import org.thingsboard.server.common.transport.activity.ActivityState;
+import org.thingsboard.server.queue.util.TbCoreComponent;
 
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
@@ -44,6 +45,7 @@ import java.util.function.Supplier;
 
 @Slf4j
 @Component
+@TbCoreComponent
 @ConditionalOnProperty(prefix = "integrations.activity", value = "reporting_strategy", havingValue = "last")
 public class LastOnlyIntegrationActivityManager extends AbstractActivityManager<IntegrationActivityKey, ActivityState> {
 

common/transport/transport-api/src/main/java/org/thingsboard/server/common/transport/service/activity/FirstAndLastTransportActivityManager.java

@@ -48,6 +48,7 @@ import org.thingsboard.server.common.transport.activity.ActivityReportCallback;
 import org.thingsboard.server.common.transport.service.SessionMetaData;
 import org.thingsboard.server.common.transport.service.TransportActivityState;
 import org.thingsboard.server.gen.transport.TransportProtos;
+import org.thingsboard.server.queue.util.TbTransportComponent;
 
 import java.util.Map;
 import java.util.UUID;
@@ -60,6 +61,7 @@ import static org.thingsboard.server.common.transport.service.DefaultTransportSe
 
 @Slf4j
 @Component
+@TbTransportComponent
 @ConditionalOnProperty(prefix = "transport.activity", value = "reporting_strategy", havingValue = "first-and-last")
 public class FirstAndLastTransportActivityManager extends AbstractActivityManager<UUID, TransportActivityState> {
 

common/transport/transport-api/src/main/java/org/thingsboard/server/common/transport/service/activity/FirstOnlyTransportActivityManager.java

@@ -48,6 +48,7 @@ import org.thingsboard.server.common.transport.activity.ActivityReportCallback;
 import org.thingsboard.server.common.transport.service.SessionMetaData;
 import org.thingsboard.server.common.transport.service.TransportActivityState;
 import org.thingsboard.server.gen.transport.TransportProtos;
+import org.thingsboard.server.queue.util.TbTransportComponent;
 
 import java.util.Map;
 import java.util.UUID;
@@ -60,6 +61,7 @@ import static org.thingsboard.server.common.transport.service.DefaultTransportSe
 
 @Slf4j
 @Component
+@TbTransportComponent
 @ConditionalOnProperty(prefix = "transport.activity", value = "reporting_strategy", havingValue = "first")
 public class FirstOnlyTransportActivityManager extends AbstractActivityManager<UUID, TransportActivityState> {
 

common/transport/transport-api/src/main/java/org/thingsboard/server/common/transport/service/activity/LastOnlyTransportActivityManager.java

@@ -41,6 +41,7 @@ import org.thingsboard.server.common.transport.activity.ActivityReportCallback;
 import org.thingsboard.server.common.transport.service.SessionMetaData;
 import org.thingsboard.server.common.transport.service.TransportActivityState;
 import org.thingsboard.server.gen.transport.TransportProtos;
+import org.thingsboard.server.queue.util.TbTransportComponent;
 
 import java.util.Map;
 import java.util.UUID;
@@ -53,6 +54,7 @@ import static org.thingsboard.server.common.transport.service.DefaultTransportSe
 
 @Slf4j
 @Component
+@TbTransportComponent
 @ConditionalOnProperty(prefix = "transport.activity", value = "reporting_strategy", havingValue = "last")
 public class LastOnlyTransportActivityManager extends AbstractActivityManager<UUID, TransportActivityState> {