@InterfaceAudience.Private public class AsyncServerResponseHandler extends io.netty.channel.ChannelInboundHandlerAdapter
| Modifier and Type | Field and Description |
|---|---|
private AsyncRpcChannel |
channel |
| Constructor and Description |
|---|
AsyncServerResponseHandler(AsyncRpcChannel channel)
Constructor
|
| Modifier and Type | Method and Description |
|---|---|
void |
channelRead(io.netty.channel.ChannelHandlerContext ctx,
Object msg) |
private org.apache.hadoop.ipc.RemoteException |
createRemoteException(org.apache.hadoop.hbase.protobuf.generated.RPCProtos.ExceptionResponse e) |
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggeredensureNotSharable, handlerAdded, handlerRemoved, isSharableprivate final AsyncRpcChannel channel
public AsyncServerResponseHandler(AsyncRpcChannel channel)
channel - on which this response handler operatespublic void channelRead(io.netty.channel.ChannelHandlerContext ctx,
Object msg)
throws Exception
channelRead in interface io.netty.channel.ChannelInboundHandlerchannelRead in class io.netty.channel.ChannelInboundHandlerAdapterExceptionprivate org.apache.hadoop.ipc.RemoteException createRemoteException(org.apache.hadoop.hbase.protobuf.generated.RPCProtos.ExceptionResponse e)
e - Proto exceptioneCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.