|
|
@ -249,7 +249,8 @@ public class RedisConnection implements RedisCommands {
|
|
|
|
private void close() {
|
|
|
|
private void close() {
|
|
|
|
CommandData<?, ?> command = getCurrentCommand();
|
|
|
|
CommandData<?, ?> command = getCurrentCommand();
|
|
|
|
if (!isActive()
|
|
|
|
if (!isActive()
|
|
|
|
|| (command != null && command.isBlockingCommand())) {
|
|
|
|
|| (command != null && command.isBlockingCommand())
|
|
|
|
|
|
|
|
|| !connectionPromise.isDone()) {
|
|
|
|
channel.close();
|
|
|
|
channel.close();
|
|
|
|
} else {
|
|
|
|
} else {
|
|
|
|
RFuture<Void> f = async(RedisCommands.QUIT);
|
|
|
|
RFuture<Void> f = async(RedisCommands.QUIT);
|
|
|
|