refactor: remove unused methods in replica session (#143)

src/main/java/com/xiaomi/infra/pegasus/rpc/async/ReplicaSession.java

@@ -40,7 +40,7 @@
 
 public class ReplicaSession {
   public static class RequestEntry {
-    public int sequenceId;
+    int sequenceId;
     public com.xiaomi.infra.pegasus.operator.client_operator op;
     public Runnable callback;
     public ScheduledFuture<?> timeoutTask;
@@ -84,24 +84,11 @@ public void initChannel(SocketChannel ch) {
     this.firstRecentTimedOutMs = new AtomicLong(0);
   }
 
-  // You can specify a message response filter with constructor or with "setMessageResponseFilter"
-  // function.
-  // the mainly usage of filter is test, in which you can control whether to abaondon a response
-  // and how to abandon it, so as to emulate some network failure cases
-  public ReplicaSession(
-      rpc_address address,
-      EventLoopGroup rpcGroup,
-      int socketTimeout,
-      MessageResponseFilter filter) {
-    this(address, rpcGroup, socketTimeout, (ReplicaSessionInterceptorManager) null);
-    this.filter = filter;
-  }
-
-  public void setMessageResponseFilter(MessageResponseFilter filter) {
+  void setMessageResponseFilter(MessageResponseFilter filter) {
     this.filter = filter;
   }
 
-  public int asyncSend(
+  public void asyncSend(
       client_operator op,
       Runnable callbackFunc,
       long timeoutInMilliseconds,
@@ -135,7 +122,6 @@ public int asyncSend(
       }
       tryConnect();
     }
-    return entry.sequenceId;
   }
 
   public void closeSession() {

src/main/java/com/xiaomi/infra/pegasus/rpc/async/ThriftFrameEncoder.java

@@ -25,7 +25,6 @@
 import org.apache.thrift.protocol.TBinaryProtocol;
 import org.slf4j.Logger;
 
-/** Created by [email protected] on 16-11-9. */
 public class ThriftFrameEncoder extends MessageToByteEncoder<ReplicaSession.RequestEntry> {
   private static final Logger logger = org.slf4j.LoggerFactory.getLogger(ThriftFrameEncoder.class);
 
@@ -60,12 +59,4 @@ protected void encode(ChannelHandlerContext ctx, ReplicaSession.RequestEntry e,
         e.op.prepare_thrift_header(
             meta_length, out.readableBytes() - ThriftHeader.HEADER_LENGTH - meta_length));
   }
-
-  @Override
-  public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
-    logger.warn(
-        "got exception in outbound handler of {}, just ignore this: ",
-        ctx.channel().toString(),
-        cause);
-  }
 }