Deprecate JedisPoolAbstract

src/main/java/redis/clients/jedis/Jedis.java

@@ -29,13 +29,14 @@
 import redis.clients.jedis.params.ZAddParams;
 import redis.clients.jedis.params.ZIncrByParams;
 import redis.clients.jedis.params.LPosParams;
+import redis.clients.jedis.util.Pool;
 import redis.clients.jedis.util.SafeEncoder;
 import redis.clients.jedis.util.Slowlog;
 
 public class Jedis extends BinaryJedis implements JedisCommands, MultiKeyCommands,
     AdvancedJedisCommands, ScriptingCommands, BasicCommands, ClusterCommands, SentinelCommands, ModuleCommands {
 
-  protected JedisPoolAbstract dataSource = null;
+  private Pool<Jedis> dataSource = null;
 
   public Jedis() {
     super();
@@ -3603,7 +3604,7 @@ public Map<String, String> pubsubNumSub(String... channels) {
   @Override
   public void close() {
     if (dataSource != null) {
-      JedisPoolAbstract pool = this.dataSource;
+      Pool<Jedis> pool = this.dataSource;
       this.dataSource = null;
       if (client.isBroken()) {
         pool.returnBrokenResource(this);

src/main/java/redis/clients/jedis/JedisPool.java

@@ -6,7 +6,6 @@
 import javax.net.ssl.SSLParameters;
 import javax.net.ssl.SSLSocketFactory;
 
-import org.apache.commons.pool2.impl.GenericObjectPool;
 import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
 
 import redis.clients.jedis.exceptions.JedisException;
@@ -29,26 +28,24 @@ public JedisPool(String host, int port) {
   public JedisPool(final String host) {
     URI uri = URI.create(host);
     if (JedisURIHelper.isValid(uri)) {
-      this.internalPool = new GenericObjectPool<>(new JedisFactory(uri,
-          Protocol.DEFAULT_TIMEOUT, Protocol.DEFAULT_TIMEOUT, null), new GenericObjectPoolConfig());
+      initPool(new GenericObjectPoolConfig(), new JedisFactory(uri, Protocol.DEFAULT_TIMEOUT,
+          Protocol.DEFAULT_TIMEOUT, null));
     } else {
-      this.internalPool = new GenericObjectPool<>(new JedisFactory(host,
-          Protocol.DEFAULT_PORT, Protocol.DEFAULT_TIMEOUT, Protocol.DEFAULT_TIMEOUT, null,
-          Protocol.DEFAULT_DATABASE, null), new GenericObjectPoolConfig());
+      initPool(new GenericObjectPoolConfig(), new JedisFactory(host, Protocol.DEFAULT_PORT,
+          Protocol.DEFAULT_TIMEOUT, Protocol.DEFAULT_TIMEOUT, null, Protocol.DEFAULT_DATABASE, null));
     }
   }
 
   public JedisPool(final String host, final SSLSocketFactory sslSocketFactory,
       final SSLParameters sslParameters, final HostnameVerifier hostnameVerifier) {
     URI uri = URI.create(host);
     if (JedisURIHelper.isValid(uri)) {
-      this.internalPool = new GenericObjectPool<>(new JedisFactory(uri,
-          Protocol.DEFAULT_TIMEOUT, Protocol.DEFAULT_TIMEOUT, null, sslSocketFactory, sslParameters,
-          hostnameVerifier), new GenericObjectPoolConfig());
+      initPool(new GenericObjectPoolConfig(), new JedisFactory(uri, Protocol.DEFAULT_TIMEOUT,
+          Protocol.DEFAULT_TIMEOUT, null, sslSocketFactory, sslParameters, hostnameVerifier));
     } else {
-      this.internalPool = new GenericObjectPool<>(new JedisFactory(host,
-          Protocol.DEFAULT_PORT, Protocol.DEFAULT_TIMEOUT, Protocol.DEFAULT_TIMEOUT, null,
-          Protocol.DEFAULT_DATABASE, null, false, null, null, null), new GenericObjectPoolConfig());
+      initPool(new GenericObjectPoolConfig(), new JedisFactory(host, Protocol.DEFAULT_PORT,
+          Protocol.DEFAULT_TIMEOUT, Protocol.DEFAULT_TIMEOUT, null, Protocol.DEFAULT_DATABASE, null,
+          false, null, null, null));
     }
   }
 
@@ -333,21 +330,20 @@ public Jedis getResource() {
   }
 
   @Override
-  protected void returnBrokenResource(final Jedis resource) {
+  public void returnBrokenResource(final Jedis resource) {
     if (resource != null) {
       returnBrokenResourceObject(resource);
     }
   }
 
   @Override
-  protected void returnResource(final Jedis resource) {
+  public void returnResource(final Jedis resource) {
     if (resource != null) {
       try {
         resource.resetState();
         returnResourceObject(resource);
       } catch (Exception e) {
         returnBrokenResource(resource);
-        throw new JedisException("Resource is returned to the pool as broken", e);
       }
     }
   }

src/main/java/redis/clients/jedis/JedisPoolAbstract.java

@@ -5,6 +5,11 @@
 
 import redis.clients.jedis.util.Pool;
 
+/**
+ * @deprecated This class will be removed in future. If you are directly manipulating this class,
+ * you are suggested to change your code to use {@link Pool Pool<Jedis>} instead.
+ */
+@Deprecated
 public class JedisPoolAbstract extends Pool<Jedis> {
 
   public JedisPoolAbstract() {
@@ -14,14 +19,4 @@ public JedisPoolAbstract() {
   public JedisPoolAbstract(GenericObjectPoolConfig poolConfig, PooledObjectFactory<Jedis> factory) {
     super(poolConfig, factory);
   }
-
-  @Override
-  protected void returnBrokenResource(Jedis resource) {
-    super.returnBrokenResource(resource);
-  }
-
-  @Override
-  protected void returnResource(Jedis resource) {
-    super.returnResource(resource);
-  }
 }

src/main/java/redis/clients/jedis/JedisSentinelPool.java

@@ -197,11 +197,9 @@ private void initPool(HostAndPort master) {
           initPool(poolConfig, factory);
         } else {
           factory.setHostAndPort(currentHostMaster);
-          // although we clear the pool, we still have to check the
-          // returned object
-          // in getResource, this call only clears idle instances, not
-          // borrowed instances
-          internalPool.clear();
+          // although we clear the pool, we still have to check the returned object in getResource,
+          // this call only clears idle instances, not borrowed instances
+          clearInternalPool();
         }
 
         log.info("Created JedisPool to master at {}", master);
@@ -312,14 +310,14 @@ public Jedis getResource() {
   }
 
   @Override
-  protected void returnBrokenResource(final Jedis resource) {
+  public void returnBrokenResource(final Jedis resource) {
     if (resource != null) {
       returnBrokenResourceObject(resource);
     }
   }
 
   @Override
-  protected void returnResource(final Jedis resource) {
+  public void returnResource(final Jedis resource) {
     if (resource != null) {
       try {
         resource.resetState();

src/main/java/redis/clients/jedis/ShardedJedisPool.java

@@ -39,14 +39,14 @@ public ShardedJedis getResource() {
   }
 
   @Override
-  protected void returnBrokenResource(final ShardedJedis resource) {
+  public void returnBrokenResource(final ShardedJedis resource) {
     if (resource != null) {
       returnBrokenResourceObject(resource);
     }
   }
 
   @Override
-  protected void returnResource(final ShardedJedis resource) {
+  public void returnResource(final ShardedJedis resource) {
     if (resource != null) {
       resource.resetState();
       returnResourceObject(resource);

src/main/java/redis/clients/jedis/util/Pool.java

@@ -12,6 +12,11 @@
 import redis.clients.jedis.exceptions.JedisExhaustedPoolException;
 
 public abstract class Pool<T> implements Closeable {
+
+  /**
+   * @deprecated This will be private in future;
+   */
+  @Deprecated
   protected GenericObjectPool<T> internalPool;
 
   /**
@@ -45,6 +50,12 @@ public void initPool(final GenericObjectPoolConfig poolConfig, PooledObjectFacto
     this.internalPool = new GenericObjectPool<>(factory, poolConfig);
   }
 
+  protected void clearInternalPool() {
+    if (internalPool != null) {
+      internalPool.clear();
+    }
+  }
+
   public T getResource() {
     try {
       return internalPool.borrowObject();
@@ -61,23 +72,20 @@ public T getResource() {
   }
 
   protected void returnResourceObject(final T resource) {
-    if (resource == null) {
-      return;
-    }
     try {
       internalPool.returnObject(resource);
     } catch (Exception e) {
       throw new JedisException("Could not return the resource to the pool", e);
     }
   }
 
-  protected void returnBrokenResource(final T resource) {
+  public void returnBrokenResource(final T resource) {
     if (resource != null) {
       returnBrokenResourceObject(resource);
     }
   }
 
-  protected void returnResource(final T resource) {
+  public void returnResource(final T resource) {
     if (resource != null) {
       returnResourceObject(resource);
     }