HTTP support in http-recorder (#527)

wvlet · Jul 2, 2019 · 4365522 · 4365522
1 parent a283f70
commit 4365522
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/airframe-http-recorder/src/main/scala/wvlet/airframe/http/recorder/HttpRecorder.scala b/airframe-http-recorder/src/main/scala/wvlet/airframe/http/recorder/HttpRecorder.scala
@@ -70,16 +70,21 @@ object HttpRecorder extends LogSupport {
     )
 
     debug(s"dest: ${recorderConfig.destAddress}")
-    val destClient =
+    val clientBuilder =
       ClientBuilder()
         .stack(Http.client)
         .name(s"airframe-http-recorder-proxy")
         .dest(recorderConfig.destAddress.hostAndPort)
-        .tls(SSLContext.getDefault)
         .noFailureAccrual
         .keepAlive(true)
         .retryPolicy(RetryPolicy.tries(3, RetryPolicy.TimeoutAndWriteExceptionsOnly))
-        .build()
+
+
+    val destClient = (if(recorderConfig.destAddress.port == 443) {
+      clientBuilder.tls(SSLContext.getDefault)
+    } else {
+      clientBuilder
+    }).build()
 
     new HttpRecorderServer(recorder, finagleConfig, new RecordingService(recorder, destClient))
   }