From 3bcb892dd5a61ec33b8f79902cd9f3a324582572 Mon Sep 17 00:00:00 2001
From: CalvinKirs <kirs@apache.org>
Date: Wed, 13 Jan 2021 14:00:38 +0800
Subject: [PATCH] rpc

---
 .../remote/rpc/remote/NettyChannel.java       |  8 ++++
 .../remote/rpc/remote/NettyClientHandler.java | 40 +++++++++++++++++++
 2 files changed, 48 insertions(+)
 create mode 100644 dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/remote/NettyChannel.java
 create mode 100644 dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/remote/NettyClientHandler.java

diff --git a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/remote/NettyChannel.java b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/remote/NettyChannel.java
new file mode 100644
index 0000000000..a38f7df4a5
--- /dev/null
+++ b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/remote/NettyChannel.java
@@ -0,0 +1,8 @@
+package org.apache.dolphinscheduler.remote.rpc.remote;
+
+/**
+ * @author jiangli
+ * @date 2021-01-13 13:51
+ */
+public class NettyChannel {
+}
diff --git a/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/remote/NettyClientHandler.java b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/remote/NettyClientHandler.java
new file mode 100644
index 0000000000..69189ca32a
--- /dev/null
+++ b/dolphinscheduler-remote/src/main/java/org/apache/dolphinscheduler/remote/rpc/remote/NettyClientHandler.java
@@ -0,0 +1,40 @@
+package org.apache.dolphinscheduler.remote.rpc.remote;
+
+
+import io.netty.channel.ChannelHandler;
+import io.netty.channel.ChannelHandlerContext;
+import io.netty.channel.ChannelInboundHandlerAdapter;
+
+/**
+ * @author jiangli
+ * @date 2021-01-13 13:33
+ */
+@ChannelHandler.Sharable
+public class NettyClientHandler extends ChannelInboundHandlerAdapter {
+
+
+    @Override
+    public void channelRegistered(ChannelHandlerContext ctx) throws Exception {
+        super.channelRegistered(ctx);
+    }
+
+    @Override
+    public void channelActive(ChannelHandlerContext ctx) throws Exception {
+        super.channelActive(ctx);
+    }
+
+    @Override
+    public void channelInactive(ChannelHandlerContext ctx) throws Exception {
+        super.channelInactive(ctx);
+    }
+
+    @Override
+    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+        super.channelRead(ctx, msg);
+    }
+
+    @Override
+    public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
+        super.userEventTriggered(ctx, evt);
+    }
+}