private static final class HttpProxyExample.RequestHandler extends org.apache.hbase.thirdparty.io.netty.channel.SimpleChannelInboundHandler<org.apache.hbase.thirdparty.io.netty.handler.codec.http.FullHttpRequest>
Modifier and Type | Field and Description |
---|---|
private org.apache.hbase.thirdparty.io.netty.channel.group.ChannelGroup |
channelGroup |
private AsyncConnection |
conn |
Constructor and Description |
---|
RequestHandler(AsyncConnection conn,
org.apache.hbase.thirdparty.io.netty.channel.group.ChannelGroup channelGroup) |
Modifier and Type | Method and Description |
---|---|
void |
channelActive(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx) |
void |
channelInactive(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx) |
protected void |
channelRead0(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
org.apache.hbase.thirdparty.io.netty.handler.codec.http.FullHttpRequest req) |
void |
exceptionCaught(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
Throwable cause) |
private void |
get(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
org.apache.hbase.thirdparty.io.netty.handler.codec.http.FullHttpRequest req) |
private HttpProxyExample.Params |
parse(org.apache.hbase.thirdparty.io.netty.handler.codec.http.FullHttpRequest req) |
private void |
put(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
org.apache.hbase.thirdparty.io.netty.handler.codec.http.FullHttpRequest req) |
private void |
write(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
org.apache.hbase.thirdparty.io.netty.handler.codec.http.HttpResponseStatus status) |
private void |
write(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
org.apache.hbase.thirdparty.io.netty.handler.codec.http.HttpResponseStatus status,
String content) |
acceptInboundMessage, channelRead
channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
private final AsyncConnection conn
private final org.apache.hbase.thirdparty.io.netty.channel.group.ChannelGroup channelGroup
public RequestHandler(AsyncConnection conn, org.apache.hbase.thirdparty.io.netty.channel.group.ChannelGroup channelGroup)
public void channelActive(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx)
channelActive
in interface org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandler
channelActive
in class org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandlerAdapter
public void channelInactive(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx)
channelInactive
in interface org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandler
channelInactive
in class org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandlerAdapter
private void write(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, org.apache.hbase.thirdparty.io.netty.handler.codec.http.HttpResponseStatus status)
private void write(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, org.apache.hbase.thirdparty.io.netty.handler.codec.http.HttpResponseStatus status, String content)
private HttpProxyExample.Params parse(org.apache.hbase.thirdparty.io.netty.handler.codec.http.FullHttpRequest req)
private void get(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, org.apache.hbase.thirdparty.io.netty.handler.codec.http.FullHttpRequest req)
private void put(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, org.apache.hbase.thirdparty.io.netty.handler.codec.http.FullHttpRequest req)
protected void channelRead0(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, org.apache.hbase.thirdparty.io.netty.handler.codec.http.FullHttpRequest req)
channelRead0
in class org.apache.hbase.thirdparty.io.netty.channel.SimpleChannelInboundHandler<org.apache.hbase.thirdparty.io.netty.handler.codec.http.FullHttpRequest>
public void exceptionCaught(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
exceptionCaught
in interface org.apache.hbase.thirdparty.io.netty.channel.ChannelHandler
exceptionCaught
in interface org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandler
exceptionCaught
in class org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandlerAdapter
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.