Merge pull request #12497 from YevhenBondarenko/fix/prod-5464
fixed NPE in sendRpcResponseToTbCore
This commit is contained in:
commit
cf53074d13
@ -115,8 +115,9 @@ public class DefaultTbRuleEngineRpcService implements TbRuleEngineDeviceRpcServi
|
||||
ToDeviceRpcRequest request = new ToDeviceRpcRequest(src.getRequestUUID(), src.getTenantId(), src.getDeviceId(),
|
||||
src.isOneway(), src.getExpirationTime(), new ToDeviceRpcRequestBody(src.getMethod(), src.getBody()), src.isPersisted(), src.getRetries(), src.getAdditionalInfo());
|
||||
forwardRpcRequestToDeviceActor(request, response -> {
|
||||
if (src.isRestApiCall()) {
|
||||
sendRpcResponseToTbCore(src.getOriginServiceId(), response);
|
||||
String originServiceId = src.getOriginServiceId();
|
||||
if (src.isRestApiCall() && originServiceId != null) {
|
||||
sendRpcResponseToTbCore(originServiceId, response);
|
||||
}
|
||||
consumer.accept(RuleEngineDeviceRpcResponse.builder()
|
||||
.deviceId(src.getDeviceId())
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user