Fixed - releaseConnection may not execute correctly

Signed-off-by: seakider <seakider@gmail.com>
pull/5883/head
seakider 11 months ago
parent f0b08cbdfc
commit ef97459b64

@ -100,8 +100,11 @@ public class RedisQueuedBatchExecutor<V, R> extends BaseRedisBatchExecutor<V, R>
|| RedisCommands.DISCARD.getName().equals(command.getName())) { || RedisCommands.DISCARD.getName().equals(command.getName())) {
if (attempt < attempts if (attempt < attempts
&& attemptPromise.isCompletedExceptionally()) { && attemptPromise.isCompletedExceptionally()) {
Throwable cause = cause(attemptPromise);
if (cause instanceof CancellationException) {
return; return;
} }
}
super.releaseConnection(attemptPromise, connectionFuture); super.releaseConnection(attemptPromise, connectionFuture);
} }

Loading…
Cancel
Save