diff --git a/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java b/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java index e8fb19737..1bd1dba10 100644 --- a/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java +++ b/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java @@ -452,7 +452,7 @@ abstract class ConnectionPool { } public void returnConnection(ClientConnectionsEntry entry, T connection) { - if (entry.isFreezed() && !entry.isMasterForRead()) { + if (entry.isFreezed() && entry.getFreezeReason() != FreezeReason.SYSTEM) { connection.closeAsync(); entry.getAllConnections().remove(connection); } else {