[INLONG-11595][SDK] Optimize the implementation of node connection ma…

…nagement
apache · Dec 11, 2024 · 5bdd39e · 5bdd39e
1 parent 2527746
commit 5bdd39e
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 5 deletions.
diff --git a/...dk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/ClientHandler.java b/...dk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/ClientHandler.java
@@ -40,10 +40,10 @@ public ClientHandler(Sender sender, ClientMgr clientMgr) {
     }
 
     @Override
-    public void channelRead0(ChannelHandlerContext ctx, EncodeObject e) {
+    public void channelRead0(ChannelHandlerContext ctx, EncodeObject encodeObject) {
         try {
-            if (e.getMsgtype() != 8) {
-                sender.notifyFeedback(ctx.channel(), e);
+            if (encodeObject.getMsgtype() != 8) {
+                sender.notifyFeedback(ctx.channel(), encodeObject);
             }
         } catch (Throwable ex) {
             if (thrownCnt.shouldPrint()) {

diff --git a/...-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/NettyClient.java b/...-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/NettyClient.java
@@ -80,7 +80,6 @@ public boolean connect(boolean needPrint) {
 
             public void operationComplete(ChannelFuture arg0) throws Exception {
                 awaitLatch.countDown();
-                // logger.debug("Connect to {} ack!", hostInfo.getReferenceName());
             }
         });
         try {
@@ -127,7 +126,6 @@ public boolean close(boolean needPrint) {
 
                     public void operationComplete(ChannelFuture arg0) throws Exception {
                         awaitLatch.countDown();
-                        // logger.debug("Close client {} acked", hostInfo.getReferenceName());
                     }
                 });
                 // Wait until the connection is close.