|
|
@ -82,6 +82,7 @@ public abstract class BaseConnectionHandler<C extends RedisConnection> extends C
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
if (futures.isEmpty()) {
|
|
|
|
if (futures.isEmpty()) {
|
|
|
|
|
|
|
|
ctx.fireChannelActive();
|
|
|
|
connectionPromise.trySuccess(connection);
|
|
|
|
connectionPromise.trySuccess(connection);
|
|
|
|
return;
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
@ -97,7 +98,7 @@ public abstract class BaseConnectionHandler<C extends RedisConnection> extends C
|
|
|
|
return;
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (commandsCounter.decrementAndGet() == 0) {
|
|
|
|
if (commandsCounter.decrementAndGet() == 0) {
|
|
|
|
BaseConnectionHandler.super.channelActive(ctx);
|
|
|
|
ctx.fireChannelActive();
|
|
|
|
connectionPromise.trySuccess(connection);
|
|
|
|
connectionPromise.trySuccess(connection);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|