Commit 0bf7d316e2cb661aac068b87f25a1b6108afe5f5
Merge branch 'master' of github.com:thingsboard/thingsboard
Showing
1 changed file
with
1 additions
and
1 deletions
@@ -63,7 +63,7 @@ public class TbRpcService { | @@ -63,7 +63,7 @@ public class TbRpcService { | ||
63 | 63 | ||
64 | private void pushRpcMsgToRuleEngine(TenantId tenantId, Rpc rpc) { | 64 | private void pushRpcMsgToRuleEngine(TenantId tenantId, Rpc rpc) { |
65 | TbMsg msg = TbMsg.newMsg("RPC_" + rpc.getStatus().name(), rpc.getDeviceId(), TbMsgMetaData.EMPTY, JacksonUtil.toString(rpc)); | 65 | TbMsg msg = TbMsg.newMsg("RPC_" + rpc.getStatus().name(), rpc.getDeviceId(), TbMsgMetaData.EMPTY, JacksonUtil.toString(rpc)); |
66 | - tbClusterService.pushMsgToRuleEngine(tenantId, rpc.getId(), msg, null); | 66 | + tbClusterService.pushMsgToRuleEngine(tenantId, rpc.getDeviceId(), msg, null); |
67 | } | 67 | } |
68 | 68 | ||
69 | public Rpc findRpcById(TenantId tenantId, RpcId rpcId) { | 69 | public Rpc findRpcById(TenantId tenantId, RpcId rpcId) { |