[rocketmq] branch develop updated: [ISSUE #6547] Some RemotingChannel calls need to be forwarded to the original Channel (#6548)

[kaili]

This is an automated email from the ASF dual-hosted git repository.

kaili pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 7dc9942fe [ISSUE #6547] Some RemotingChannel calls need to be 
forwarded to the original Channel (#6548)
7dc9942fe is described below

commit 7dc9942fe20dfee8841221e55c904f872c994d38
Author: lk <xdk...@outlook.com>
AuthorDate: Tue Apr 11 10:33:44 2023 +0800

    [ISSUE #6547] Some RemotingChannel calls need to be forwarded to the 
original Channel (#6548)
---
 .../proxy/remoting/channel/RemotingChannel.java        | 18 ++++++++++++++++++
 1 file changed, 18 insertions(+)

diff --git 
a/proxy/src/main/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannel.java
 
b/proxy/src/main/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannel.java
index 368330115..40946cabf 100644
--- 
a/proxy/src/main/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannel.java
+++ 
b/proxy/src/main/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannel.java
@@ -21,7 +21,10 @@ import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.TypeReference;
 import com.google.common.base.MoreObjects;
 import io.netty.channel.Channel;
+import io.netty.channel.ChannelConfig;
+import io.netty.channel.ChannelFuture;
 import io.netty.channel.ChannelFutureListener;
+import io.netty.channel.ChannelMetadata;
 import java.time.Duration;
 import java.util.Set;
 import java.util.concurrent.CompletableFuture;
@@ -91,6 +94,21 @@ public class RemotingChannel extends ProxyChannel implements 
RemoteChannelConver
         return this.parent().isWritable();
     }
 
+    @Override
+    public ChannelFuture close() {
+        return this.parent().close();
+    }
+
+    @Override
+    public ChannelConfig config() {
+        return this.parent().config();
+    }
+
+    @Override
+    public ChannelMetadata metadata() {
+        return this.parent().metadata();
+    }
+
     @Override
     protected CompletableFuture<Void> processOtherMessage(Object msg) {
         this.parent().writeAndFlush(msg);