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()); }