@@ -0,0 +1,1495 @@
+package net.rubyeye.xmemcached.test.unittest;%0D%0A%0D%0Aimport java.net.InetSocketAddress;%0D%0Aimport java.util.List;%0D%0A%0D%0Aimport net.rubyeye.xmemcached.MemcachedClientBuilder;%0D%0Aimport net.rubyeye.xmemcached.XMemcachedClientBuilder;%0D%0Aimport net.rubyeye.xmemcached.command.BinaryCommandFactory;%0D%0Aimport net.rubyeye.xmemcached.impl.KetamaMemcachedSessionLocator;%0D%0Aimport net.rubyeye.xmemcached.utils.AddrUtil;%0D%0A%0D%0Apublic class ConnectionPoolMemcachedClientTest extends XMemcachedClientTest %7B%0D%0A%09private static final int CONNECTION_POOL_SIZE = 3;%0D%0A%0D%0A%09@Override%0D%0A%09public MemcachedClientBuilder createBuilder() throws Exception %7B%0D%0A%09%09MemcachedClientBuilder builder = new XMemcachedClientBuilder(AddrUtil%0D%0A%09%09%09%09.getAddresses(this.properties%0D%0A%09%09%09%09%09%09.getProperty(%22test.memcached.servers%22)));%0D%0A%09%09builder.setConnectionPoolSize(CONNECTION_POOL_SIZE);%0D%0A%09%09return builder;%0D%0A%09%7D%0D%0A%0D%0A%09@Override%0D%0A%09public MemcachedClientBuilder createWeightedBuilder() throws Exception %7B%0D%0A%09%09List%3CInetSocketAddress%3E addressList = AddrUtil%0D%0A%09%09%09%09.getAddresses(this.properties%0D%0A%09%09%09%09%09%09.getProperty(%22test.memcached.servers%22));%0D%0A%09%09int%5B%5D weights = new int%5BaddressList.size()%5D;%0D%0A%09%09for (int i = 0; i %3C weights.length; i++) %7B%0D%0A%09%09%09weights%5Bi%5D = i + 1;%0D%0A%09%09%7D%0D%0A%0D%0A%09%09MemcachedClientBuilder builder = new XMemcachedClientBuilder(%0D%0A%09%09%09%09addressList, weights);%0D%0A%09%09builder.setConnectionPoolSize(CONNECTION_POOL_SIZE);%0D%0A%09%09builder.setCommandFactory(new BinaryCommandFactory());%0D%0A%09%09builder.setSessionLocator(new KetamaMemcachedSessionLocator());%0D%0A%09%09return builder;%0D%0A%09%7D%0D%0A%7D%0D%0A

Add connection pool client unit test.