Fixed - Pooled connection closed after MOVED redirection #1778

6 years ago · cbafc09d2b
parent ce5a17fd29
commit cbafc09d2b
1 changed files with 1 additions and 1 deletions
--- 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<T extends RedisConnection> {
    }

    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 {