com.baidu.brpc.protocol.http

Class BrpcHttpObjectAggregator

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.baidu.brpc.protocol.http.BrpcHttpObjectAggregator

All Implemented Interfaces:

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

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

Migrate from netty HttpObjectAggregator

Since:

2019-01-07

Author:

wangjiayin@baidu.com

Nested Class Summary

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

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor and Description
BrpcHttpObjectAggregator(int maxContentLength)

Method Summary

Modifier and Type	Method and Description
void	abort() Abort aggregation and release underlying resources
void	aggregate(io.netty.channel.ChannelHandlerContext ctx, Object msg, List<Object> out)

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

aggregate, beginAggregation, closeAfterContinueResponse, finishAggregation, handleOversizedMessage, ignoreContentAfterContinueResponse, isAggregated, isContentLengthInvalid, isContentMessage, isLastContentMessage, isStartMessage, newContinueResponse

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

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

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

channelRead

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught, 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 Detail

BrpcHttpObjectAggregator

public BrpcHttpObjectAggregator(int maxContentLength)

Method Detail

aggregate

public void aggregate(io.netty.channel.ChannelHandlerContext ctx,
                      Object msg,
                      List<Object> out)
               throws Exception

Throws:

Exception

abort

public void abort()

Abort aggregation and release underlying resources

FIXME find a better way to release memory