Fixed - CommandDecoder.messageDecoder() method throws NPE if RBatch object used with executionMode = IN_MEMORY. (regression since 3.18.1) #4725

pull/4733/head
Nikita Koksharov 2 years ago
parent 717f74c291
commit 0e5c759602

@ -98,7 +98,7 @@ public class CommandDecoder extends ReplayingDecoder<State> {
}
}
} else {
if (!holder.getChannelPromise().isSuccess()) {
if (holder.getChannelPromise().isDone() && !holder.getChannelPromise().isSuccess()) {
sendNext(ctx.channel());
// throw REPLAY error
in.indexOf(Integer.MAX_VALUE/2, Integer.MAX_VALUE, (byte) 0);

@ -187,7 +187,7 @@ public class RedisExecutor<V, R> {
TimerTask task = timeout -> {
if (connectionFuture.cancel(false)) {
exception = new RedisTimeoutException("Unable to acquire connection! " + this.connectionFuture +
"Increase connection pool size. "
"Increase connection pool size or timeout. "
+ "Node source: " + source
+ ", command: " + LogHelper.toString(command, params)
+ " after " + attempt + " retry attempts");

Loading…
Cancel
Save