@InterfaceAudience.Private class NettyRpcServerResponseEncoder extends org.apache.hbase.thirdparty.io.netty.channel.ChannelOutboundHandlerAdapter
RpcResponse
.Modifier and Type | Field and Description |
---|---|
private MetricsHBaseServer |
metrics |
Constructor and Description |
---|
NettyRpcServerResponseEncoder(MetricsHBaseServer metrics) |
Modifier and Type | Method and Description |
---|---|
void |
write(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
Object msg,
org.apache.hbase.thirdparty.io.netty.channel.ChannelPromise promise) |
bind, close, connect, deregister, disconnect, flush, read
ensureNotSharable, exceptionCaught, handlerAdded, handlerRemoved, isSharable
private final MetricsHBaseServer metrics
NettyRpcServerResponseEncoder(MetricsHBaseServer metrics)
public void write(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, Object msg, org.apache.hbase.thirdparty.io.netty.channel.ChannelPromise promise) throws Exception
write
in interface org.apache.hbase.thirdparty.io.netty.channel.ChannelOutboundHandler
write
in class org.apache.hbase.thirdparty.io.netty.channel.ChannelOutboundHandlerAdapter
Exception
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.