@@ -0,0 +1,727 @@
+package alluxio.worker.netty;%0A%0Aimport alluxio.network.protocol.RPCProtoMessage;%0Aimport io.netty.channel.ChannelHandlerContext;%0Aimport io.netty.channel.ChannelInboundHandlerAdapter;%0A%0A/**%0A * Handler for async cache requests.%0A */%0Apublic class AsyncCacheHandler extends ChannelInboundHandlerAdapter %7B%0A  /**%0A   * Constructs a new async cache handler.%0A   */%0A  public AsyncCacheHandler() %7B%7D%0A%0A  @Override%0A  public void channelRead(ChannelHandlerContext ctx, Object object) throws Exception %7B%0A    if (object instanceof RPCProtoMessage%0A        && ((RPCProtoMessage) object).getMessage().isAsyncCacheRequest()) %7B%0A      ctx.writeAndFlush(RPCProtoMessage.createOkResponse(null));%0A    %7D else %7B%0A      ctx.fireChannelRead(object);%0A    %7D%0A  %7D%0A%7D%0A

Add a dummy async cache handler.