Export remoting client for dledger server (#172)

Author: RongtongJin

src/main/java/io/openmessaging/storage/dledger/DLedgerRpcNettyService.java

@@ -493,4 +493,8 @@ public void setdLedgerServer(DLedgerServer dLedgerServer) {
     public NettyRemotingServer getRemotingServer() {
         return remotingServer;
     }
+
+    public NettyRemotingClient getRemotingClient() {
+        return remotingClient;
+    }
 }

src/main/java/io/openmessaging/storage/dledger/DLedgerServer.java

@@ -59,6 +59,7 @@
 
 import org.apache.rocketmq.remoting.ChannelEventListener;
 import org.apache.rocketmq.remoting.netty.NettyClientConfig;
+import org.apache.rocketmq.remoting.netty.NettyRemotingClient;
 import org.apache.rocketmq.remoting.netty.NettyRemotingServer;
 import org.apache.rocketmq.remoting.netty.NettyServerConfig;
 import org.slf4j.Logger;
@@ -83,11 +84,17 @@ public DLedgerServer(DLedgerConfig dLedgerConfig) {
         this(dLedgerConfig, null, null, null);
     }
 
-    public DLedgerServer(DLedgerConfig dLedgerConfig, NettyServerConfig nettyServerConfig, NettyClientConfig nettyClientConfig) {
+    public DLedgerServer(DLedgerConfig dLedgerConfig, NettyServerConfig nettyServerConfig) {
+        this(dLedgerConfig, nettyServerConfig, null, null);
+    }
+
+    public DLedgerServer(DLedgerConfig dLedgerConfig, NettyServerConfig nettyServerConfig,
+        NettyClientConfig nettyClientConfig) {
         this(dLedgerConfig, nettyServerConfig, nettyClientConfig, null);
     }
 
-    public DLedgerServer(DLedgerConfig dLedgerConfig, NettyServerConfig nettyServerConfig, NettyClientConfig nettyClientConfig, ChannelEventListener channelEventListener) {
+    public DLedgerServer(DLedgerConfig dLedgerConfig, NettyServerConfig nettyServerConfig,
+        NettyClientConfig nettyClientConfig, ChannelEventListener channelEventListener) {
         this.dLedgerConfig = dLedgerConfig;
         this.memberState = new MemberState(dLedgerConfig);
         this.dLedgerStore = createDLedgerStore(dLedgerConfig.getStoreType(), this.dLedgerConfig, this.memberState);
@@ -452,8 +459,16 @@ public DLedgerConfig getdLedgerConfig() {
 
     public NettyRemotingServer getRemotingServer() {
         if (this.dLedgerRpcService instanceof DLedgerRpcNettyService) {
-            return ((DLedgerRpcNettyService)this.dLedgerRpcService).getRemotingServer();
+            return ((DLedgerRpcNettyService) this.dLedgerRpcService).getRemotingServer();
+        }
+        return null;
+    }
+
+    public NettyRemotingClient getRemotingClient() {
+        if (this.dLedgerRpcService instanceof DLedgerRpcNettyService) {
+            return ((DLedgerRpcNettyService) this.dLedgerRpcService).getRemotingClient();
         }
         return null;
     }
+
 }