com.xjeffrose.xio.handler.codec.http

Class HttpStreamDecoder

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.handler.codec.MessageToMessageDecoder<I>

io.netty.handler.codec.MessageAggregator<io.netty.handler.codec.http.HttpObject,io.netty.handler.codec.http.HttpMessage,io.netty.handler.codec.http.HttpContent,io.netty.handler.codec.http.FullHttpMessage>

io.netty.handler.codec.http.HttpObjectAggregator

com.xjeffrose.xio.handler.codec.http.HttpStreamDecoder

All Implemented Interfaces:

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

public class HttpStreamDecoder
extends io.netty.handler.codec.http.HttpObjectAggregator

Tries to aggregate an HttpObject stream to a single FullHttpRequest if possible, otherwise allows the stream to pass through.

Nested Class Summary

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

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor and Description
HttpStreamDecoder(int maxContentLength)

Method Summary

Modifier and Type	Method and Description
protected io.netty.handler.codec.http.FullHttpMessage	beginAggregation(io.netty.handler.codec.http.HttpMessage httpMessage, io.netty.buffer.ByteBuf byteBuf)
void	channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg)
protected boolean	closeAfterContinueResponse(Object o)
protected void	decode(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http.HttpObject msg, List<Object> out)
protected void	finishAggregation(io.netty.handler.codec.http.FullHttpMessage aggregated)
protected void	handleOversizedMessage(io.netty.channel.ChannelHandlerContext ctx, io.netty.handler.codec.http.HttpMessage oversized)
protected boolean	ignoreContentAfterContinueResponse(Object o)
protected Object	newContinueResponse(io.netty.handler.codec.http.HttpMessage httpMessage, int i, io.netty.channel.ChannelPipeline pipeline)

Methods inherited from class io.netty.handler.codec.http.HttpObjectAggregator

aggregate, isAggregated, isContentLengthInvalid, isContentMessage, isLastContentMessage, isStartMessage

Methods inherited from class io.netty.handler.codec.MessageAggregator

acceptInboundMessage, channelInactive, ctx, handlerAdded, handlerRemoved, isHandlingOversizedMessage, maxContentLength, maxCumulationBufferComponents, setMaxCumulationBufferComponents

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

isSharable

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpStreamDecoder

public HttpStreamDecoder(int maxContentLength)

Method Detail

newContinueResponse

protected Object newContinueResponse(io.netty.handler.codec.http.HttpMessage httpMessage,
                                     int i,
                                     io.netty.channel.ChannelPipeline pipeline)

Overrides:

newContinueResponse in class io.netty.handler.codec.http.HttpObjectAggregator

closeAfterContinueResponse

protected boolean closeAfterContinueResponse(Object o)

Overrides:

closeAfterContinueResponse in class io.netty.handler.codec.http.HttpObjectAggregator

ignoreContentAfterContinueResponse

protected boolean ignoreContentAfterContinueResponse(Object o)

Overrides:

ignoreContentAfterContinueResponse in class io.netty.handler.codec.http.HttpObjectAggregator

beginAggregation

protected io.netty.handler.codec.http.FullHttpMessage beginAggregation(io.netty.handler.codec.http.HttpMessage httpMessage,
                                                                       io.netty.buffer.ByteBuf byteBuf)
                                                                throws Exception

Overrides:

beginAggregation in class io.netty.handler.codec.http.HttpObjectAggregator

Throws:

Exception

finishAggregation

protected void finishAggregation(io.netty.handler.codec.http.FullHttpMessage aggregated)
                          throws Exception

Overrides:

finishAggregation in class io.netty.handler.codec.http.HttpObjectAggregator

Throws:

Exception

handleOversizedMessage

protected void handleOversizedMessage(io.netty.channel.ChannelHandlerContext ctx,
                                      io.netty.handler.codec.http.HttpMessage oversized)
                               throws Exception

Overrides:

handleOversizedMessage in class io.netty.handler.codec.http.HttpObjectAggregator

Throws:

Exception

decode

protected void decode(io.netty.channel.ChannelHandlerContext ctx,
                      io.netty.handler.codec.http.HttpObject msg,
                      List<Object> out)
               throws Exception

Overrides:

decode in class io.netty.handler.codec.MessageAggregator<io.netty.handler.codec.http.HttpObject,io.netty.handler.codec.http.HttpMessage,io.netty.handler.codec.http.HttpContent,io.netty.handler.codec.http.FullHttpMessage>

Throws:

Exception

channelRead

public void channelRead(io.netty.channel.ChannelHandlerContext ctx,
                        Object msg)
                 throws Exception

Specified by:

channelRead in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelRead in class io.netty.handler.codec.MessageToMessageDecoder<io.netty.handler.codec.http.HttpObject>

Throws:

Exception