diff --git a/redisson/src/main/java/org/redisson/connection/ClientConnectionsEntry.java b/redisson/src/main/java/org/redisson/connection/ClientConnectionsEntry.java index a7fdcdcf7..b83e7a2e7 100644 --- a/redisson/src/main/java/org/redisson/connection/ClientConnectionsEntry.java +++ b/redisson/src/main/java/org/redisson/connection/ClientConnectionsEntry.java @@ -151,6 +151,10 @@ public class ClientConnectionsEntry { } public void releaseConnection(RedisConnection connection) { + if (connection.isClosed()) { + return; + } + if (client != connection.getRedisClient()) { connection.closeAsync(); return; @@ -225,6 +229,10 @@ public class ClientConnectionsEntry { } public void releaseSubscribeConnection(RedisPubSubConnection connection) { + if (connection.isClosed()) { + return; + } + if (client != connection.getRedisClient()) { connection.closeAsync(); return;