From 9553a6958b313ae85a463609e25d88c6232e963c Mon Sep 17 00:00:00 2001 From: YevhenBondarenko Date: Wed, 29 Nov 2023 16:46:35 +0100 Subject: [PATCH] fixed persistent RPC for microservice deployment --- .../java/org/thingsboard/server/service/queue/ProtoUtils.java | 1 + 1 file changed, 1 insertion(+) diff --git a/application/src/main/java/org/thingsboard/server/service/queue/ProtoUtils.java b/application/src/main/java/org/thingsboard/server/service/queue/ProtoUtils.java index 36038568bc..b61bd9b67e 100644 --- a/application/src/main/java/org/thingsboard/server/service/queue/ProtoUtils.java +++ b/application/src/main/java/org/thingsboard/server/service/queue/ProtoUtils.java @@ -308,6 +308,7 @@ public class ProtoUtils { .setRequestIdMSB(msg.getMsg().getId().getMostSignificantBits()) .setRequestIdLSB(msg.getMsg().getId().getLeastSignificantBits()) .setOneway(msg.getMsg().isOneway()) + .setPersisted(msg.getMsg().isPersisted()) .build(); return TransportProtos.ToDeviceRpcRequestActorMsgProto.newBuilder()