removed RpcError
This commit is contained in:
parent
06078a3163
commit
f1bb232d24
@ -518,7 +518,7 @@ class DeviceActorMessageProcessor extends AbstractContextAwareMsgProcessor {
|
|||||||
String payload = hasError ? responseMsg.getError() : responseMsg.getPayload();
|
String payload = hasError ? responseMsg.getError() : responseMsg.getPayload();
|
||||||
systemContext.getTbCoreDeviceRpcService().processRpcResponseFromDeviceActor(
|
systemContext.getTbCoreDeviceRpcService().processRpcResponseFromDeviceActor(
|
||||||
new FromDeviceRpcResponse(requestMd.getMsg().getMsg().getId(),
|
new FromDeviceRpcResponse(requestMd.getMsg().getMsg().getId(),
|
||||||
payload, hasError ? RpcError.INTERNAL : null));
|
payload, null));
|
||||||
if (requestMd.getMsg().getMsg().isPersisted()) {
|
if (requestMd.getMsg().getMsg().isPersisted()) {
|
||||||
RpcStatus status = hasError ? RpcStatus.FAILED : RpcStatus.SUCCESSFUL;
|
RpcStatus status = hasError ? RpcStatus.FAILED : RpcStatus.SUCCESSFUL;
|
||||||
JsonNode response;
|
JsonNode response;
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user