fix grpc client add tls (#262)

primihub · Jul 4, 2024 · 0893368 · 0893368
1 parent 04d9feb
commit 0893368
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/primihub-sdk/src/main/java/com/primihub/sdk/grpc/channel/GrpcChannel.java b/primihub-sdk/src/main/java/com/primihub/sdk/grpc/channel/GrpcChannel.java
@@ -53,8 +53,9 @@ public GrpcChannel(GrpcClientConfig grpcClientConfig) throws Exception {
                     .negotiationType(NegotiationType.TLS)
                     .sslContext(sslContext)
                     .build();
+        } else {
+            getDefaultTypeChannel(grpcClientConfig.getAddress(), grpcClientConfig.getPort());
         }
-        getDefaultTypeChannel(grpcClientConfig.getAddress(), grpcClientConfig.getPort());
     }
 
     private void getDefaultTypeChannel(String grpcClientAddress,Integer grpcClientPort){

diff --git a/primihub-sdk/src/main/java/com/primihub/sdk/task/TaskHelper.java b/primihub-sdk/src/main/java/com/primihub/sdk/task/TaskHelper.java
@@ -93,8 +93,9 @@ public void initGrpcClientChannel() throws Exception {
                     .negotiationType(NegotiationType.TLS)
                     .sslContext(sslContext)
                     .build();
+        } else {
+            getDefaultTypeChannel(grpcClientConfig.getAddress(), grpcClientConfig.getPort());
         }
-        getDefaultTypeChannel(grpcClientConfig.getAddress(), grpcClientConfig.getPort());
     }