refactoring

e8ced7c6 · Nikita Koksharov · cf372193 · e8ced7c6
隐藏空白更改
内联并排

Showing with 2 addition and 1 deletion

redisson/src/main/java/org/redisson/client/RedisConnection.java ...on/src/main/java/org/redisson/client/RedisConnection.java +2 -1

未找到文件。
--- a/redisson/src/main/java/org/redisson/client/RedisConnection.java
+++ b/redisson/src/main/java/org/redisson/client/RedisConnection.java
@@ -248,7 +248,8 @@ public class RedisConnection implements RedisCommands {
    
    private void close() {
        CommandData<?, ?> command = getCurrentCommand();
-        if (command != null && command.isBlockingCommand()) {
+        if (!isActive()
+                || (command != null && command.isBlockingCommand())) {
            channel.close();
        } else {
            RFuture<Void> f = async(RedisCommands.QUIT);