|
|
@ -117,11 +117,6 @@ public class RedisCommonBatchExecutor extends RedisExecutor<Object, Void> {
|
|
|
|
writeFuture = connection.send(new CommandsData(attemptPromise, list, options.isSkipResult(), isAtomic, isQueued, options.getSyncSlaves() > 0));
|
|
|
|
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) {
|
|
|
|
protected boolean isWaitCommand(CommandData<?, ?> c) {
|
|
|
|
return c.getCommand().getName().equals(RedisCommands.WAIT.getName());
|
|
|
|
return c.getCommand().getName().equals(RedisCommands.WAIT.getName());
|
|
|
|
}
|
|
|
|
}
|
|
|
|