refactoring

4 years ago · 2ca883533b
parent fefabcc065
commit 2ca883533b
1 changed files with 1 additions and 2 deletions
--- a/redisson/src/main/java/org/redisson/connection/ClientConnectionsEntry.java
+++ b/redisson/src/main/java/org/redisson/connection/ClientConnectionsEntry.java
@ -243,8 +243,7 @@ public class ClientConnectionsEntry {
            freeConnections.add(connection);
            return;
        }
-        connection.decUsage();
+        if (connection.decUsage() == 0 && connection.isPooled()) {
        if (connection.isPooled() && connection.getUsage() == 0) {
            freeConnections.add(connection);
            connection.setPooled(false);
        }