From 723928443e2e025d2e2869c89a8aa9e6a3389a8a Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Fri, 15 Apr 2022 08:27:26 +0300 Subject: [PATCH] Fixed - Unable to connect to Redis server error is thrown due to NPE #4231 --- .../java/org/redisson/client/handler/CommandsQueue.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/redisson/src/main/java/org/redisson/client/handler/CommandsQueue.java b/redisson/src/main/java/org/redisson/client/handler/CommandsQueue.java index 69a3e6082..75eb29ba2 100644 --- a/redisson/src/main/java/org/redisson/client/handler/CommandsQueue.java +++ b/redisson/src/main/java/org/redisson/client/handler/CommandsQueue.java @@ -24,7 +24,6 @@ import org.redisson.client.protocol.QueueCommand; import org.redisson.client.protocol.QueueCommandHolder; import org.redisson.misc.LogHelper; -import java.net.SocketAddress; import java.util.Deque; import java.util.Iterator; import java.util.Queue; @@ -42,9 +41,8 @@ public class CommandsQueue extends ChannelDuplexHandler { public static final AttributeKey> COMMANDS_QUEUE = AttributeKey.valueOf("COMMANDS_QUEUE"); @Override - public void connect(ChannelHandlerContext ctx, SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) throws Exception { - super.connect(ctx, remoteAddress, localAddress, promise); - + public void channelRegistered(ChannelHandlerContext ctx) throws Exception { + super.channelRegistered(ctx); ctx.channel().attr(COMMANDS_QUEUE).set(new ConcurrentLinkedDeque<>()); }