Taxonomy and Terms

Author: ishaileshmishra

src/main/java/com/contentstack/cms/Contentstack.java

@@ -8,6 +8,7 @@
 import com.contentstack.cms.stack.Stack;
 import com.contentstack.cms.user.User;
 import com.google.gson.Gson;
+import okhttp3.ConnectionPool;
 import okhttp3.OkHttpClient;
 import okhttp3.ResponseBody;
 import okhttp3.logging.HttpLoggingInterceptor;
@@ -22,6 +23,7 @@
 import java.util.HashMap;
 import java.util.Map;
 import java.util.Objects;
+import java.util.concurrent.TimeUnit;
 import java.util.logging.Logger;
 
 import static com.contentstack.cms.core.Util.*;
@@ -467,6 +469,12 @@ public static class Builder {
         private int timeout = Util.TIMEOUT; // Default timeout 30 seconds
         private Boolean retry = Util.RETRY_ON_FAILURE;// Default base url for contentstack
 
+        /**
+         * Default ConnectionPool holds up to 5 idle connections which
+         * will be evicted after 5 minutes of inactivity.
+         */
+        private ConnectionPool connectionPool = new ConnectionPool(); // Connection
+
         /**
          * Instantiates a new Builder.
          */
@@ -479,11 +487,12 @@ public Builder() {
          * Proxy(Proxy.Type.HTTP, new
          * InetSocketAddress(proxyHost, proxyPort));
          * <br>
-         *
-         * <pre>
-         * {
-         *     Proxy proxy = new Proxy(Proxy.Type.HTTP, new InetSocketAddress("hostname", 433));
-         *     Contentstack contentstack = new Contentstack.Builder().setProxy(proxy).build();
+         * <p>
+         * {@code
+         * <p>
+         * Proxy proxy = new Proxy(Proxy.Type.HTTP, new InetSocketAddress("hostname", 433));
+         * Contentstack contentstack = new Contentstack.Builder().setProxy(proxy).build();
+         * <p>
          * }
          * </pre>
          *
@@ -550,6 +559,36 @@ public Builder setTimeout(int timeout) {
             return this;
         }
 
+
+        /**
+         * Create a new connection pool with tuning parameters appropriate for a single-user application.
+         * The tuning parameters in this pool are subject to change in future OkHttp releases. Currently,
+         * this pool holds up to 5 idle connections which will be evicted after 5 minutes of inactivity.
+         * <p>
+         * <p>
+         * public ConnectionPool() {
+         * this(5, 5, TimeUnit.MINUTES);
+         * }
+         *
+         * @param maxIdleConnections Maximum number of idle connections
+         * @param keepAliveDuration  The Keep Alive Duration
+         * @param timeUnit           A TimeUnit represents time durations at a given unit of granularity and provides utility methods to convert across units
+         * @return instance of Builder
+         * <p>
+         * Example:
+         * {@code
+         * Contentstack cs = new Contentstack.Builder()
+         * .setAuthtoken(AUTHTOKEN)
+         * .setConnectionPool(5, 400, TimeUnit.MILLISECONDS)
+         * .setHost("host")
+         * .build();
+         * Connection}
+         */
+        public Builder setConnectionPool(int maxIdleConnections, int keepAliveDuration, TimeUnit timeUnit) {
+            this.connectionPool = new ConnectionPool(maxIdleConnections, keepAliveDuration, timeUnit);
+            return this;
+        }
+
         /**
          * Sets authtoken for the client
          *
@@ -582,7 +621,9 @@ private void validateClient(Contentstack contentstack) {
 
         private OkHttpClient httpClient(Contentstack contentstack, Boolean retryOnFailure) {
             this.authInterceptor = contentstack.interceptor = new AuthInterceptor();
-            return new OkHttpClient.Builder().addInterceptor(this.authInterceptor)
+            return new OkHttpClient.Builder()
+                    .connectionPool(this.connectionPool)
+                    .addInterceptor(this.authInterceptor)
                     .addInterceptor(logger())
                     .proxy(this.proxy)
                     .connectTimeout(Duration.ofSeconds(this.timeout))

src/test/java/com/contentstack/cms/TestClient.java

@@ -5,6 +5,7 @@
 import io.github.cdimascio.dotenv.Dotenv;
 
 import java.util.HashMap;
+import java.util.concurrent.TimeUnit;
 
 public class TestClient {
 
@@ -41,14 +42,20 @@ public static Contentstack getCustomClient() {
         if (instance == null) {
             synchronized (Contentstack.class) {
                 if (instance == null) {
-                    instance = new Contentstack.Builder().setAuthtoken(AUTHTOKEN)
+                    instance = new Contentstack.Builder()
+                            .setAuthtoken(AUTHTOKEN)
+                            .setConnectionPool(5, 400, TimeUnit.MILLISECONDS)
                             .setHost("kpm.ishaileshmishra.io/path/another").build();
                 }
             }
         }
         return instance;
     }
 
+    public static void main(String[] args) {
+        getCustomClient();
+    }
+
     public static Stack getStack() {
         HashMap<String, Object> headers = new HashMap<>();
         headers.put(Util.API_KEY, API_KEY);