|
|
|
@ -757,8 +757,8 @@ public class DefaultTransportService implements TransportService { |
|
|
|
ruleEngineMsgProducer.send(tpi, new TbProtoQueueMsg<>(tbMsg.getId(), msg), wrappedCallback); |
|
|
|
} |
|
|
|
|
|
|
|
protected void sendToRuleEngine(TenantId tenantId, DeviceId deviceId, SessionInfoProto sessionInfo, JsonObject json, |
|
|
|
TbMsgMetaData metaData, SessionMsgType sessionMsgType, TbQueueCallback callback) { |
|
|
|
protected void sendToRuleEngine(TenantId tenantId, DeviceId deviceId, TransportProtos.SessionInfoProto sessionInfo, JsonObject json, |
|
|
|
TbMsgMetaData metaData, SessionMsgType sessionMsgType, TbQueueCallback callback) { |
|
|
|
DeviceProfileId deviceProfileId = new DeviceProfileId(new UUID(sessionInfo.getDeviceProfileIdMSB(), sessionInfo.getDeviceProfileIdLSB())); |
|
|
|
DeviceProfile deviceProfile = deviceProfileCache.get(deviceProfileId); |
|
|
|
RuleChainId ruleChainId; |
|
|
|
|