Showing
1 changed file
with
2 additions
and
0 deletions
| @@ -60,6 +60,7 @@ import org.thingsboard.server.queue.TbQueueProducer; | @@ -60,6 +60,7 @@ import org.thingsboard.server.queue.TbQueueProducer; | ||
| 60 | import org.thingsboard.server.queue.common.TbProtoQueueMsg; | 60 | import org.thingsboard.server.queue.common.TbProtoQueueMsg; |
| 61 | import org.thingsboard.server.queue.discovery.PartitionService; | 61 | import org.thingsboard.server.queue.discovery.PartitionService; |
| 62 | import org.thingsboard.server.queue.provider.TbQueueProducerProvider; | 62 | import org.thingsboard.server.queue.provider.TbQueueProducerProvider; |
| 63 | +import org.thingsboard.server.queue.util.TbCoreComponent; | ||
| 63 | import org.thingsboard.server.service.state.DeviceStateService; | 64 | import org.thingsboard.server.service.state.DeviceStateService; |
| 64 | 65 | ||
| 65 | import java.util.Collections; | 66 | import java.util.Collections; |
| @@ -70,6 +71,7 @@ import java.util.concurrent.locks.ReentrantLock; | @@ -70,6 +71,7 @@ import java.util.concurrent.locks.ReentrantLock; | ||
| 70 | 71 | ||
| 71 | @Service | 72 | @Service |
| 72 | @Slf4j | 73 | @Slf4j |
| 74 | +@TbCoreComponent | ||
| 73 | public class DeviceProvisionServiceImpl implements DeviceProvisionService { | 75 | public class DeviceProvisionServiceImpl implements DeviceProvisionService { |
| 74 | 76 | ||
| 75 | protected TbQueueProducer<TbProtoQueueMsg<ToRuleEngineMsg>> ruleEngineMsgProducer; | 77 | protected TbQueueProducer<TbProtoQueueMsg<ToRuleEngineMsg>> ruleEngineMsgProducer; |