diff --git a/src/main/java/org/redisson/misc/ConnectionPool.java b/src/main/java/org/redisson/misc/ConnectionPool.java index ae851565e..9692cdbdb 100644 --- a/src/main/java/org/redisson/misc/ConnectionPool.java +++ b/src/main/java/org/redisson/misc/ConnectionPool.java @@ -128,9 +128,12 @@ public class ConnectionPool { } } - Promise promise = connectionManager.newPromise(); - promises.add(promise); - return promise; + RedisConnectionException exception = new RedisConnectionException( + "Can't aquire connection from pool"); + return connectionManager.newFailedFuture(exception); +// Promise promise = connectionManager.newPromise(); +// promises.add(promise); +// return promise; } public Future get(ClientConnectionsEntry entry) {