added cp validateAfterInactivityMs config variable

Author: mahendya1002

java/src/main/java/com/cybersource/ws/client/MerchantConfig.java

@@ -69,6 +69,7 @@ public class MerchantConfig {
     private int socketTimeoutMs;
     private int evictThreadSleepTimeMs;
     private int maxKeepAliveTimeMs;
+    private int validateAfterInactivityMs;
     private int timeout;
     private String proxyHost;
     private int proxyPort;
@@ -324,6 +325,16 @@ public int getMaxKeepAliveTimeMs() {
         return maxKeepAliveTimeMs;
     }
 
+    /**
+     * Defines period of inactivity in milliseconds after which persistent connections must be re-validated prior to being
+     * leased to the consumer. Non-positive value passed to this method disables connection validation.
+     * This check helps detect connections that have become stale (half-closed) while kept inactive in the pool.
+     * @return int
+     */
+    public int getValidateAfterInactivityMs() {
+        return validateAfterInactivityMs;
+    }
+
     /**
      * Getter method for proxyHost
      * @return String
@@ -569,6 +580,7 @@ public MerchantConfig(Properties _props, String _merchantID)
                 maxKeepAliveTimeMs = getIntegerProperty(merchantID, "maxKeepAliveTimeMs");
             }
 
+            validateAfterInactivityMs = getIntegerProperty(merchantID, "validateAfterInactivityMs", 2000);
             shutdownHookEnabled =getBooleanProperty(merchantID, "enabledShutdownHook", true);
         }
 
@@ -761,6 +773,7 @@ public String getLogString() {
             appendPair(sb, "socketTimeoutMs", socketTimeoutMs);
             appendPair(sb, "evictThreadSleepTimeMs", evictThreadSleepTimeMs);
             appendPair(sb, "maxKeepAliveTimeMs", maxKeepAliveTimeMs);
+            appendPair(sb, "validateAfterInactivityMs", validateAfterInactivityMs);
             appendPair(sb, "enabledShutdownHook", shutdownHookEnabled);
         }
         appendPair(sb, "timeout", timeout);

java/src/main/java/com/cybersource/ws/client/PoolingHttpClientConnection.java

@@ -77,6 +77,7 @@ private void initializeConnectionManager(MerchantConfig merchantConfig) throws C
                         connectionManager = new PoolingHttpClientConnectionManager();
                         connectionManager.setDefaultMaxPerRoute(merchantConfig.getDefaultMaxConnectionsPerRoute());
                         connectionManager.setMaxTotal(merchantConfig.getMaxConnections());
+                        connectionManager.setValidateAfterInactivity(mc.getValidateAfterInactivityMs());
                         final HttpHost httpHost = new HttpHost(hostname);
                         connectionManager.setMaxPerRoute(new HttpRoute(httpHost), merchantConfig.getMaxConnectionsPerRoute());
                         initHttpClient(merchantConfig, connectionManager);