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 7e1df96cf..839cacb2e 100644 --- a/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java +++ b/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java @@ -131,21 +131,18 @@ abstract class ConnectionPool { if (initPromise.isDone()) { return; } - for (RedisConnection connection : entry.getAllConnections()) { if (!connection.isClosed()) { connection.closeAsync(); } } entry.getAllConnections().clear(); - for (RedisConnection connection : entry.getAllSubscribeConnections()) { if (!connection.isClosed()) { connection.closeAsync(); } } entry.getAllSubscribeConnections().clear(); - int totalInitializedConnections = minimumIdleSize - initializedConnections.get(); String errorMsg; if (totalInitializedConnections == 0) {