From 46cbb2e186faf09ba0a72bf578c1f8a8a1b84562 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Mon, 15 Feb 2021 15:54:13 +0300 Subject: [PATCH] Fixed - internal RedissonBaseLock.evalWriteAsync() method isn't executed again if cluster slaves amount > 0 #3419 --- .../java/org/redisson/command/RedisCommonBatchExecutor.java | 5 ----- 1 file changed, 5 deletions(-) diff --git a/redisson/src/main/java/org/redisson/command/RedisCommonBatchExecutor.java b/redisson/src/main/java/org/redisson/command/RedisCommonBatchExecutor.java index 0d7200329..4c15ac469 100644 --- a/redisson/src/main/java/org/redisson/command/RedisCommonBatchExecutor.java +++ b/redisson/src/main/java/org/redisson/command/RedisCommonBatchExecutor.java @@ -117,11 +117,6 @@ public class RedisCommonBatchExecutor extends RedisExecutor { writeFuture = connection.send(new CommandsData(attemptPromise, list, options.isSkipResult(), isAtomic, isQueued, options.getSyncSlaves() > 0)); } - @Override - protected boolean isResendAllowed(int attempt, int attempts) { - return options.getSyncSlaves() == 0 && super.isResendAllowed(attempt, attempts); - } - protected boolean isWaitCommand(CommandData c) { return c.getCommand().getName().equals(RedisCommands.WAIT.getName()); }