Package com.linkedin.alpini.netty4.handlers

Class AsyncFullHttpRequestHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

com.linkedin.alpini.netty4.handlers.ChannelInitializer<io.netty.channel.Channel>

com.linkedin.alpini.netty4.handlers.AsyncFullHttpRequestHandler

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

@Sharable
public class AsyncFullHttpRequestHandler
extends ChannelInitializer<io.netty.channel.Channel>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	AsyncFullHttpRequestHandler.RequestHandler

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor	Description
AsyncFullHttpRequestHandler(AsyncFullHttpRequestHandler.RequestHandler handler, BooleanSupplier shutdownFlag)
AsyncFullHttpRequestHandler(AsyncFullHttpRequestHandler.RequestHandler handler, BooleanSupplier shutdownFlag, BooleanSupplier busyAutoReadDisable)

Method Summary

Modifier and Type	Method	Description
protected io.netty.handler.codec.http.FullHttpResponse	buildErrorResponse(io.netty.handler.codec.http.HttpRequest msg, Throwable ex)
protected io.netty.handler.codec.http.FullHttpResponse	buildErrorResponse(io.netty.handler.codec.http.HttpRequest msg, Throwable ex, io.netty.handler.codec.http.HttpResponseStatus responseStatus)
protected io.netty.handler.codec.http.HttpResponseStatus	getResponseStatus(Throwable ex)
protected void	initChannel(io.netty.channel.Channel ch)	This method will be called once the Channel was registered.
protected io.netty.channel.ChannelFuture	writeAndFlushResponse(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http.FullHttpResponse msg)

Methods inherited from class com.linkedin.alpini.netty4.handlers.ChannelInitializer

channelRegistered, currentContext, exceptionCaught, handlerAdded, handlerRemoved

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelRead, channelReadComplete, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, isSharable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AsyncFullHttpRequestHandler

public AsyncFullHttpRequestHandler(@Nonnull
 AsyncFullHttpRequestHandler.RequestHandler handler,
 @Nonnull
 BooleanSupplier shutdownFlag)

AsyncFullHttpRequestHandler

public AsyncFullHttpRequestHandler(@Nonnull
 AsyncFullHttpRequestHandler.RequestHandler handler,
 @Nonnull
 BooleanSupplier shutdownFlag,
 @Nonnull
 BooleanSupplier busyAutoReadDisable)

Method Details

initChannel

protected void initChannel(io.netty.channel.Channel ch)
                    throws Exception

Description copied from class: ChannelInitializer

This method will be called once the Channel was registered. After the method returns this instance will be removed from the ChannelPipeline of the Channel.

Specified by:

initChannel in class ChannelInitializer<io.netty.channel.Channel>

Parameters:

ch - the Channel which was registered.

Throws:

Exception - is thrown if an error occurs. In that case it will be handled by ChannelInitializer.exceptionCaught(ChannelHandlerContext, Throwable) which will by default close the Channel.

writeAndFlushResponse

protected io.netty.channel.ChannelFuture writeAndFlushResponse(io.netty.channel.ChannelHandlerContext ctx,
 io.netty.handler.codec.http.FullHttpResponse msg)

getResponseStatus

@Nonnull
protected io.netty.handler.codec.http.HttpResponseStatus getResponseStatus(@Nonnull
 Throwable ex)

buildErrorResponse

@Nonnull
protected io.netty.handler.codec.http.FullHttpResponse buildErrorResponse(@Nonnull
 io.netty.handler.codec.http.HttpRequest msg,
 @Nonnull
 Throwable ex)

buildErrorResponse

@Nonnull
protected io.netty.handler.codec.http.FullHttpResponse buildErrorResponse(@Nonnull
 io.netty.handler.codec.http.HttpRequest msg,
 @Nonnull
 Throwable ex,
 @Nonnull
 io.netty.handler.codec.http.HttpResponseStatus responseStatus)