From aae9ac9edae57aa397fd97fcf00357330b6c3007 Mon Sep 17 00:00:00 2001 From: ShvaykaD Date: Tue, 12 Nov 2024 17:45:15 +0200 Subject: [PATCH] added fix for SEQUENTIAL_ON_RESPONSE_FROM_DEVICE rpc submit strategy --- .../server/actors/device/DeviceActorMessageProcessor.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/application/src/main/java/org/thingsboard/server/actors/device/DeviceActorMessageProcessor.java b/application/src/main/java/org/thingsboard/server/actors/device/DeviceActorMessageProcessor.java index 3a000bfe4d..04452d3fb6 100644 --- a/application/src/main/java/org/thingsboard/server/actors/device/DeviceActorMessageProcessor.java +++ b/application/src/main/java/org/thingsboard/server/actors/device/DeviceActorMessageProcessor.java @@ -257,8 +257,7 @@ public class DeviceActorMessageProcessor extends AbstractContextAwareMsgProcesso private boolean isSendNewRpcAvailable() { return switch (rpcSubmitStrategy) { case SEQUENTIAL_ON_ACK_FROM_DEVICE -> toDeviceRpcPendingMap.values().stream().filter(md -> !md.isDelivered()).findAny().isEmpty(); - case SEQUENTIAL_ON_RESPONSE_FROM_DEVICE -> - toDeviceRpcPendingMap.values().stream().filter(ToDeviceRpcRequestMetadata::isDelivered).findAny().isEmpty(); + case SEQUENTIAL_ON_RESPONSE_FROM_DEVICE -> toDeviceRpcPendingMap.isEmpty(); default -> true; }; }