From bbef215c11045878cda7440ff7d125d9a5c4f2c1 Mon Sep 17 00:00:00 2001 From: Nikita Date: Tue, 24 Nov 2015 22:50:26 +0300 Subject: [PATCH] ConnectionPool.get should return failed future in case of free connection absence. #262 --- src/main/java/org/redisson/misc/ConnectionPool.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) 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) {