Add support for all connection pool config options. Fixes #27.

Author: jcoleman

README.markdown

@@ -72,6 +72,11 @@ Copy the following files into the `TOMCAT_BASE/lib` directory:
 
 Reboot the server, and sessions should now be stored in Redis.
 
+Connection Pool Configuration
+-----------------------------
+
+All of the configuration options from both `org.apache.commons.pool2.impl.GenericObjectPoolConfig` and `org.apache.commons.pool2.impl.BaseObjectPoolConfig` are also configurable for the Redis connection pool used by the session manager. To configure any of these attributes (e.g., `maxIdle` and `testOnBorrow`) just use the config attribute name prefixed with `connectionPool` (e.g., `connectionPoolMaxIdle` and `connectionPoolTestOnBorrow`) and set the desired value in the `<Manager>` declaration in your Tomcat context.xml.
+
 Session Change Tracking
 -----------------------
 

src/main/java/com/radiadesign/catalina/session/RedisSessionManager.java

@@ -10,6 +10,9 @@
 import org.apache.catalina.Session;
 import org.apache.catalina.session.ManagerBase;
 
+import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
+import org.apache.commons.pool2.impl.BaseObjectPoolConfig;
+
 import redis.clients.util.Pool;
 import redis.clients.jedis.JedisPool;
 import redis.clients.jedis.JedisSentinelPool;
@@ -44,6 +47,7 @@ public class RedisSessionManager extends ManagerBase implements Lifecycle {
   Set<String> sentinelSet = null;
 
   protected Pool<Jedis> connectionPool;
+  protected JedisPoolConfig connectionPoolConfig = new JedisPoolConfig();
 
   protected RedisSessionHandlerValve handlerValve;
   protected ThreadLocal<RedisSession> currentSession = new ThreadLocal<>();
@@ -579,16 +583,15 @@ public void processExpires() {
 
   private void initializeDatabaseConnection() throws LifecycleException {
     try {
-      // TODO: Allow configuration of pool (such as size...)
       if (getSentinelMaster() != null) {
         Set<String> sentinelSet = getSentinelSet();
         if (sentinelSet != null && sentinelSet.size() > 0) {
-          connectionPool = new JedisSentinelPool(getSentinelMaster(), sentinelSet, new JedisPoolConfig(), getTimeout(), getPassword());
+          connectionPool = new JedisSentinelPool(getSentinelMaster(), sentinelSet, this.connectionPoolConfig, getTimeout(), getPassword());
         } else {
           throw new LifecycleException("Error configuring Redis Sentinel connection pool: expected both `sentinelMaster` and `sentiels` to be configured");
         }
       } else {
-        connectionPool = new JedisPool(new JedisPoolConfig(), getHost(), getPort(), getTimeout(), getPassword());
+        connectionPool = new JedisPool(this.connectionPoolConfig, getHost(), getPort(), getTimeout(), getPassword());
       }
     } catch (Exception e) {
       e.printStackTrace();
@@ -613,4 +616,152 @@ private void initializeSerializer() throws ClassNotFoundException, IllegalAccess
     }
     serializer.setClassLoader(classLoader);
   }
+
+
+  // Connection Pool Config Accessors
+
+  // - from org.apache.commons.pool2.impl.GenericObjectPoolConfig
+
+  public int getConnectionPoolMaxTotal() {
+    return this.connectionPoolConfig.getMaxTotal();
+  }
+
+  public void setConnectionPoolMaxTotal(int connectionPoolMaxTotal) {
+    this.connectionPoolConfig.setMaxTotal(connectionPoolMaxTotal);
+  }
+
+  public int getConnectionPoolMaxIdle() {
+    return this.connectionPoolConfig.getMaxIdle();
+  }
+
+  public void setConnectionPoolMaxIdle(int connectionPoolMaxIdle) {
+    this.connectionPoolConfig.setMaxIdle(connectionPoolMaxIdle);
+  }
+
+  public int getConnectionPoolMinIdle() {
+    return this.connectionPoolConfig.getMinIdle();
+  }
+
+  public void setConnectionPoolMinIdle(int connectionPoolMinIdle) {
+    this.connectionPoolConfig.setMinIdle(connectionPoolMinIdle);
+  }
+
+
+  // - from org.apache.commons.pool2.impl.BaseObjectPoolConfig
+
+  public boolean getLifo() {
+    return this.connectionPoolConfig.getLifo();
+  }
+  public void setLifo(boolean lifo) {
+    this.connectionPoolConfig.setLifo(lifo);
+  }
+  public long getMaxWaitMillis() {
+    return this.connectionPoolConfig.getMaxWaitMillis();
+  }
+
+  public void setMaxWaitMillis(long maxWaitMillis) {
+    this.connectionPoolConfig.setMaxWaitMillis(maxWaitMillis);
+  }
+
+  public long getMinEvictableIdleTimeMillis() {
+    return this.connectionPoolConfig.getMinEvictableIdleTimeMillis();
+  }
+
+  public void setMinEvictableIdleTimeMillis(long minEvictableIdleTimeMillis) {
+    this.connectionPoolConfig.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
+  }
+
+  public long getSoftMinEvictableIdleTimeMillis() {
+    return this.connectionPoolConfig.getSoftMinEvictableIdleTimeMillis();
+  }
+
+  public void setSoftMinEvictableIdleTimeMillis(long softMinEvictableIdleTimeMillis) {
+    this.connectionPoolConfig.setSoftMinEvictableIdleTimeMillis(softMinEvictableIdleTimeMillis);
+  }
+
+  public int getNumTestsPerEvictionRun() {
+    return this.connectionPoolConfig.getNumTestsPerEvictionRun();
+  }
+
+  public void setNumTestsPerEvictionRun(int numTestsPerEvictionRun) {
+    this.connectionPoolConfig.setNumTestsPerEvictionRun(numTestsPerEvictionRun);
+  }
+
+  public boolean getTestOnCreate() {
+    return this.connectionPoolConfig.getTestOnCreate();
+  }
+
+  public void setTestOnCreate(boolean testOnCreate) {
+    this.connectionPoolConfig.setTestOnCreate(testOnCreate);
+  }
+
+  public boolean getTestOnBorrow() {
+    return this.connectionPoolConfig.getTestOnBorrow();
+  }
+
+  public void setTestOnBorrow(boolean testOnBorrow) {
+    this.connectionPoolConfig.setTestOnBorrow(testOnBorrow);
+  }
+
+  public boolean getTestOnReturn() {
+    return this.connectionPoolConfig.getTestOnReturn();
+  }
+
+  public void setTestOnReturn(boolean testOnReturn) {
+    this.connectionPoolConfig.setTestOnReturn(testOnReturn);
+  }
+
+  public boolean getTestWhileIdle() {
+    return this.connectionPoolConfig.getTestWhileIdle();
+  }
+
+  public void setTestWhileIdle(boolean testWhileIdle) {
+    this.connectionPoolConfig.setTestWhileIdle(testWhileIdle);
+  }
+
+  public long getTimeBetweenEvictionRunsMillis() {
+    return this.connectionPoolConfig.getTimeBetweenEvictionRunsMillis();
+  }
+
+  public void setTimeBetweenEvictionRunsMillis(long timeBetweenEvictionRunsMillis) {
+    this.connectionPoolConfig.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
+  }
+
+  public String getEvictionPolicyClassName() {
+    return this.connectionPoolConfig.getEvictionPolicyClassName();
+  }
+
+  public void setEvictionPolicyClassName(String evictionPolicyClassName) {
+    this.connectionPoolConfig.setEvictionPolicyClassName(evictionPolicyClassName);
+  }
+
+  public boolean getBlockWhenExhausted() {
+    return this.connectionPoolConfig.getBlockWhenExhausted();
+  }
+
+  public void setBlockWhenExhausted(boolean blockWhenExhausted) {
+    this.connectionPoolConfig.setBlockWhenExhausted(blockWhenExhausted);
+  }
+
+  public boolean getJmxEnabled() {
+    return this.connectionPoolConfig.getJmxEnabled();
+  }
+
+  public void setJmxEnabled(boolean jmxEnabled) {
+    this.connectionPoolConfig.setJmxEnabled(jmxEnabled);
+  }
+  public String getJmxNameBase() {
+    return this.connectionPoolConfig.getJmxNameBase();
+  }
+  public void setJmxNameBase(String jmxNameBase) {
+    this.connectionPoolConfig.setJmxNameBase(jmxNameBase);
+  }
+
+  public String getJmxNamePrefix() {
+    return this.connectionPoolConfig.getJmxNamePrefix();
+  }
+
+  public void setJmxNamePrefix(String jmxNamePrefix) {
+    this.connectionPoolConfig.setJmxNamePrefix(jmxNamePrefix);
+  }
 }