Browse Source

fixed persistent RPC for microservice deployment

pull/9733/head
YevhenBondarenko 3 years ago
parent
commit
9553a6958b
  1. 1
      application/src/main/java/org/thingsboard/server/service/queue/ProtoUtils.java

1
application/src/main/java/org/thingsboard/server/service/queue/ProtoUtils.java

@ -308,6 +308,7 @@ public class ProtoUtils {
.setRequestIdMSB(msg.getMsg().getId().getMostSignificantBits()) .setRequestIdMSB(msg.getMsg().getId().getMostSignificantBits())
.setRequestIdLSB(msg.getMsg().getId().getLeastSignificantBits()) .setRequestIdLSB(msg.getMsg().getId().getLeastSignificantBits())
.setOneway(msg.getMsg().isOneway()) .setOneway(msg.getMsg().isOneway())
.setPersisted(msg.getMsg().isPersisted())
.build(); .build();
return TransportProtos.ToDeviceRpcRequestActorMsgProto.newBuilder() return TransportProtos.ToDeviceRpcRequestActorMsgProto.newBuilder()

Loading…
Cancel
Save