diff --git a/common/src/main/java/com/pedro/common/socket/java/TcpStreamSocketJava.kt b/common/src/main/java/com/pedro/common/socket/java/TcpStreamSocketJava.kt
index 925a2bf31..94dcf3fe8 100644
--- a/common/src/main/java/com/pedro/common/socket/java/TcpStreamSocketJava.kt
+++ b/common/src/main/java/com/pedro/common/socket/java/TcpStreamSocketJava.kt
@@ -30,6 +30,12 @@ class TcpStreamSocketJava(
         val socketAddress: SocketAddress = InetSocketAddress(host, port)
         socket.connect(socketAddress, timeout.toInt())
         socket.soTimeout = timeout.toInt()
+        if (socket is SSLSocket) {
+            socket.sslParameters = socket.sslParameters.apply {
+                endpointIdentificationAlgorithm = "HTTPS"
+            }
+            socket.startHandshake()
+        }
         return socket
     }
-}
\ No newline at end of file
+}
diff --git a/rtmp/src/main/java/com/pedro/rtmp/rtmp/RtmpClient.kt b/rtmp/src/main/java/com/pedro/rtmp/rtmp/RtmpClient.kt
index 61a9e1087..cce32fbb8 100644
--- a/rtmp/src/main/java/com/pedro/rtmp/rtmp/RtmpClient.kt
+++ b/rtmp/src/main/java/com/pedro/rtmp/rtmp/RtmpClient.kt
@@ -109,7 +109,7 @@ class RtmpClient(private val connectChecker: ConnectChecker) {
     get() = rtmpSender.getSentVideoFrames()
   val bytesSend: Long
     get() = rtmpSender.getBytesSend()
-  var socketType = SocketType.KTOR
+  var socketType = SocketType.JAVA
   var socketTimeout = StreamSocket.DEFAULT_TIMEOUT
   var shouldFailOnRead = false
   var shouldSendPings = false