REACTOR: ArucsClientPool constructor parameters.

naver · Jun 5, 2024 · 2ec8a20 · 2ec8a20
1 parent d50edf1
commit 2ec8a20
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 8 deletions.
diff --git a/src/main/java/net/spy/memcached/ArcusClient.java b/src/main/java/net/spy/memcached/ArcusClient.java
@@ -288,9 +288,7 @@ private static ArcusClientPool createArcusClient(String hostPorts, String servic
     if (serviceCode.isEmpty()) {
       throw new IllegalArgumentException("Service code is empty.");
     }
-
-    CacheManager exe = new CacheManager(hostPorts, serviceCode, cfb, poolSize, waitTimeForConnect);
-    return new ArcusClientPool(poolSize, exe.getAC());
+    return new ArcusClientPool(new CacheManager(hostPorts, serviceCode, cfb, poolSize, waitTimeForConnect));
   }
 
   /**

diff --git a/src/main/java/net/spy/memcached/ArcusClientPool.java b/src/main/java/net/spy/memcached/ArcusClientPool.java
@@ -60,11 +60,10 @@ public class ArcusClientPool implements MemcachedClientIF, ArcusClientIF {
   private final ArcusClient[] client;
   private final Random rand;
 
-  public ArcusClientPool(int poolSize, ArcusClient[] client) {
-
-    this.poolSize = poolSize;
-    this.client = client;
-    rand = new Random();
+  public ArcusClientPool(CacheManager cacheManager) {
+    this.poolSize = cacheManager.getAC().length;
+    this.client = cacheManager.getAC();
+    this.rand = new Random();
   }
 
   /**