check endpoint of OpenSergoClient

Signed-off-by: Jiangnan Jia <jnan0806@gmail.com>
opensergo · Feb 15, 2023 · 3a5bd92 · 3a5bd92
1 parent bd5f15f
commit 3a5bd92
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/main/java/io/opensergo/OpenSergoClient.java b/src/main/java/io/opensergo/OpenSergoClient.java
@@ -53,7 +53,7 @@ public class OpenSergoClient implements AutoCloseable {
     public static class Builder {
 
         private String host;
-        private int port;
+        private int port = 10246;
         private OpenSergoClientConfig openSergoConfig;
 
         public OpenSergoClient.Builder endpoint(String host, int port) {
@@ -83,6 +83,7 @@ public OpenSergoClient(String host, int port) {
     }
 
     public OpenSergoClient(String host, int port, OpenSergoClientConfig clientConfig) {
+        checkEndpoint(host, port);
         checkClientConfig(clientConfig);
         // TODO: support TLS
         this.clientConfig = clientConfig;
@@ -95,6 +96,11 @@ public OpenSergoClient(String host, int port, OpenSergoClientConfig clientConfig
         this.reqId = new AtomicInteger(0);
     }
 
+    private void checkEndpoint(String host, int port) {
+        AssertUtils.notEmpty(host, "host cannot be empty, need to give a valid host");
+        AssertUtils.isTrue(port > 0, "port < 1 is invalid, need to give a valid port");
+    }
+
     private void checkClientConfig(OpenSergoClientConfig clientConfig) {
         AssertUtils.assertNotNull(clientConfig, "clientConfig cannot be null");
     }