Tiered Storage: add OkHttp based provider for JClouds (apache#15136)

(cherry picked from commit a74527d)
datastax · Apr 14, 2022 · 45a9483 · 45a9483
1 parent c17bd3b
commit 45a9483
Show file tree

Hide file tree

Showing 2 changed files with 19 additions and 2 deletions.
diff --git a/jclouds-shaded/pom.xml b/jclouds-shaded/pom.xml
@@ -45,6 +45,17 @@
       <artifactId>jclouds-apachehc</artifactId>
       <version>${jclouds.version}</version>
     </dependency>
+    <dependency>
+      <groupId>org.apache.jclouds.driver</groupId>
+      <artifactId>jclouds-okhttp</artifactId>
+      <version>${jclouds.version}</version>
+      <exclusions>
+        <exclusion>
+          <groupId>*</groupId>
+          <artifactId>*</artifactId>
+        </exclusion>
+      </exclusions>
+    </dependency>
     <dependency>
       <groupId>org.apache.jclouds.driver</groupId>
       <artifactId>jclouds-slf4j</artifactId>

diff --git a/jclouds-shaded/src/main/java/org/apache/pulsar/jclouds/ShadedJCloudsUtils.java b/jclouds-shaded/src/main/java/org/apache/pulsar/jclouds/ShadedJCloudsUtils.java
@@ -23,6 +23,7 @@
 import lombok.extern.slf4j.Slf4j;
 import org.jclouds.ContextBuilder;
 import org.jclouds.http.apachehc.config.ApacheHCHttpCommandExecutorServiceModule;
+import org.jclouds.http.okhttp.config.OkHttpCommandExecutorServiceModule;
 import org.jclouds.logging.slf4j.config.SLF4JLoggingModule;
 
 import java.util.ArrayList;
@@ -42,9 +43,12 @@ public class ShadedJCloudsUtils {
      * Apache Http Client module should work well in all the environments.
      */
     private static final boolean ENABLE_APACHE_HC_MODULE = Boolean
-            .parseBoolean(System.getProperty("pulsar.jclouds.use_apache_hc", "true"));
+            .parseBoolean(System.getProperty("pulsar.jclouds.use_apache_hc", "false"));
+    private static final boolean ENABLE_OKHTTP_MODULE = Boolean
+            .parseBoolean(System.getProperty("pulsar.jclouds.use_okhttp", "false"));
     static {
         log.info("Considering -Dpulsar.jclouds.use_apache_hc=" + ENABLE_APACHE_HC_MODULE);
+        log.info("Considering -Dpulsar.jclouds.use_okhttp=" + ENABLE_OKHTTP_MODULE);
     }
 
     /**
@@ -54,7 +58,9 @@ public class ShadedJCloudsUtils {
     public static void addStandardModules(ContextBuilder builder) {
         List<AbstractModule> modules = new ArrayList<>();
         modules.add(new SLF4JLoggingModule());
-        if (ENABLE_APACHE_HC_MODULE) {
+        if (ENABLE_OKHTTP_MODULE) {
+            modules.add(new OkHttpCommandExecutorServiceModule());
+        } else if (ENABLE_APACHE_HC_MODULE) {
             modules.add(new ApacheHCHttpCommandExecutorServiceModule());
         }
         builder.modules(modules);