From 75f8dea252acfa9eb49a5407521c8199611810d1 Mon Sep 17 00:00:00 2001 From: Nikita Date: Fri, 1 Sep 2017 11:11:00 +0300 Subject: [PATCH] fireChannelActive should be invoked on successful connection establishment --- .../org/redisson/client/handler/BaseConnectionHandler.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/redisson/src/main/java/org/redisson/client/handler/BaseConnectionHandler.java b/redisson/src/main/java/org/redisson/client/handler/BaseConnectionHandler.java index 63daa0a71..d085ea400 100644 --- a/redisson/src/main/java/org/redisson/client/handler/BaseConnectionHandler.java +++ b/redisson/src/main/java/org/redisson/client/handler/BaseConnectionHandler.java @@ -82,6 +82,7 @@ public abstract class BaseConnectionHandler extends C } if (futures.isEmpty()) { + ctx.fireChannelActive(); connectionPromise.trySuccess(connection); return; } @@ -97,7 +98,7 @@ public abstract class BaseConnectionHandler extends C return; } if (commandsCounter.decrementAndGet() == 0) { - BaseConnectionHandler.super.channelActive(ctx); + ctx.fireChannelActive(); connectionPromise.trySuccess(connection); } }