From d9081f2b39e1ae785537240694651d8f5ff7069b Mon Sep 17 00:00:00 2001 From: Nikita Date: Mon, 26 Dec 2016 12:42:48 +0300 Subject: [PATCH] ConnectionPool size not respected during connection by Redis address --- .../org/redisson/connection/pool/ConnectionPool.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) 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 549a2ec73..4e30c1582 100644 --- a/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java +++ b/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java @@ -199,8 +199,13 @@ abstract class ConnectionPool { public RFuture get(ClientConnectionsEntry entry) { if (((entry.getNodeType() == NodeType.MASTER && entry.getFreezeReason() == FreezeReason.SYSTEM) || !entry.isFreezed()) && tryAcquireConnection(entry)) { - RPromise result = connectionManager.newPromise(); - connectTo(entry, result); + final RPromise result = connectionManager.newPromise(); + acquireConnection(entry, new Runnable() { + @Override + public void run() { + connectTo(entry, result); + } + }); return result; }