Showing
1 changed file
with
2 additions
and
0 deletions
@@ -30,6 +30,7 @@ import org.thingsboard.server.common.msg.rpc.ToDeviceRpcRequest; | @@ -30,6 +30,7 @@ import org.thingsboard.server.common.msg.rpc.ToDeviceRpcRequest; | ||
30 | import org.thingsboard.server.dao.yunteng.service.TkDeviceService; | 30 | import org.thingsboard.server.dao.yunteng.service.TkDeviceService; |
31 | import org.thingsboard.server.dao.yunteng.service.TkDeviceTaskCenterService; | 31 | import org.thingsboard.server.dao.yunteng.service.TkDeviceTaskCenterService; |
32 | import org.thingsboard.server.dao.yunteng.service.TkTaskCenterService; | 32 | import org.thingsboard.server.dao.yunteng.service.TkTaskCenterService; |
33 | +import org.thingsboard.server.queue.util.TbCoreComponent; | ||
33 | import org.thingsboard.server.service.rpc.TbCoreDeviceRpcService; | 34 | import org.thingsboard.server.service.rpc.TbCoreDeviceRpcService; |
34 | import org.thingsboard.server.service.security.model.SecurityUser; | 35 | import org.thingsboard.server.service.security.model.SecurityUser; |
35 | import java.time.LocalDateTime; | 36 | import java.time.LocalDateTime; |
@@ -39,6 +40,7 @@ import java.util.*; | @@ -39,6 +40,7 @@ import java.util.*; | ||
39 | @Component("rpcCommandTask") | 40 | @Component("rpcCommandTask") |
40 | @RequiredArgsConstructor | 41 | @RequiredArgsConstructor |
41 | @Slf4j | 42 | @Slf4j |
43 | +@TbCoreComponent | ||
42 | public class RpcCommandTask { | 44 | public class RpcCommandTask { |
43 | @Value("${server.rest.server_side_rpc.default_timeout:10000}") | 45 | @Value("${server.rest.server_side_rpc.default_timeout:10000}") |
44 | protected long defaultTimeout; | 46 | protected long defaultTimeout; |