Top Description Constructors Methods
io.netty.handler.codec.http.websocketx

public Class WebSocketFrameAggregator

extends MessageAggregator<WebSocketFrame, WebSocketFrame, ContinuationWebSocketFrame, WebSocketFrame>
Class Inheritance
Imports
io.netty.buffer.ByteBuf, io.netty.channel.ChannelPipeline, io.netty.handler.codec.MessageAggregator, .TooLongFrameException
Handler that aggregate fragmented WebSocketFrame's. Be aware if PING/PONG/CLOSE frames are send in the middle of a fragmented WebSocketFrame they will just get forwarded to the next handler in the pipeline.

Constructor Summary

AccessConstructor and Description
public
WebSocketFrameAggregator(int
If the size of the aggregated frame exceeds this value, a TooLongFrameException is thrown.
maxContentLength)

Creates a new instance

Method Summary

Modifier and TypeMethod and Description
protected WebSocketFrame
beginAggregation(WebSocketFrame start, ByteBuf content)

Implements abstract io.netty.handler.codec.MessageAggregator.beginAggregation.

Creates a new aggregated message from the specified start message and the specified content.
protected boolean
closeAfterContinueResponse(Object
The return value from newContinueResponse(Object, int, ChannelPipeline).
msg)

Implements abstract io.netty.handler.codec.MessageAggregator.closeAfterContinueResponse.

Determine if the channel should be closed after the result of newContinueResponse(Object, int, ChannelPipeline) is written.
protected boolean
ignoreContentAfterContinueResponse(Object
The return value from newContinueResponse(Object, int, ChannelPipeline).
msg)

Implements abstract io.netty.handler.codec.MessageAggregator.ignoreContentAfterContinueResponse.

Determine if all objects for the current request/response should be ignored or not.
protected boolean
isAggregated(WebSocketFrame msg)

Implements abstract io.netty.handler.codec.MessageAggregator.isAggregated.

Returns true if and only if the specified message is already aggregated.
protected boolean
isContentLengthInvalid(WebSocketFrame
The message which may indicate the content length.
start, int
The maximum allowed content length.
maxContentLength)

Implements abstract io.netty.handler.codec.MessageAggregator.isContentLengthInvalid.

Determine if the message start's content length is known, and if it greater than maxContentLength.
protected boolean
isContentMessage(WebSocketFrame msg)

Implements abstract io.netty.handler.codec.MessageAggregator.isContentMessage.

Returns true if and only if the specified message is a content message.
protected boolean
isLastContentMessage(ContinuationWebSocketFrame msg)

Implements abstract io.netty.handler.codec.MessageAggregator.isLastContentMessage.

Returns true if and only if the specified message is the last content message.
protected boolean
isStartMessage(WebSocketFrame msg)

Implements abstract io.netty.handler.codec.MessageAggregator.isStartMessage.

Returns true if and only if the specified message is a start message.
protected Object
newContinueResponse(WebSocketFrame start, int maxContentLength, ChannelPipeline pipeline)

Implements abstract io.netty.handler.codec.MessageAggregator.newContinueResponse.

Returns the 'continue response' for the specified start message if necessary.
Inherited from io.netty.handler.codec.MessageAggregator:
acceptInboundMessageaggregatechannelInactivechannelReadCompletectxdecodefinishAggregationhandleOversizedMessagehandlerAddedhandlerRemovedisHandlingOversizedMessagemaxContentLengthmaxCumulationBufferComponentssetMaxCumulationBufferComponents

Constructor Detail

WebSocketFrameAggregatorback to summary
public WebSocketFrameAggregator(int maxContentLength)

Creates a new instance

Parameters
maxContentLength:int

If the size of the aggregated frame exceeds this value, a TooLongFrameException is thrown.

Method Detail

beginAggregationback to summary
protected WebSocketFrame beginAggregation(WebSocketFrame start, ByteBuf content) throws Exception

Implements abstract io.netty.handler.codec.MessageAggregator.beginAggregation.

Doc from io.netty.handler.codec.MessageAggregator.beginAggregation.

Creates a new aggregated message from the specified start message and the specified content. If the start message implements ByteBufHolder, its content is appended to the specified content. This aggregator will continue to append the received content to the specified content.

Annotations
@Override
closeAfterContinueResponseback to summary
protected boolean closeAfterContinueResponse(Object msg) throws Exception

Implements abstract io.netty.handler.codec.MessageAggregator.closeAfterContinueResponse.

Doc from io.netty.handler.codec.MessageAggregator.closeAfterContinueResponse.

Determine if the channel should be closed after the result of newContinueResponse(Object, int, ChannelPipeline) is written.

Parameters
msg:Object

The return value from newContinueResponse(Object, int, ChannelPipeline).

Returns:boolean

true if the channel should be closed after the result of newContinueResponse(Object, int, ChannelPipeline) is written. false otherwise.

Annotations
@Override
ignoreContentAfterContinueResponseback to summary
protected boolean ignoreContentAfterContinueResponse(Object msg) throws Exception

Implements abstract io.netty.handler.codec.MessageAggregator.ignoreContentAfterContinueResponse.

Doc from io.netty.handler.codec.MessageAggregator.ignoreContentAfterContinueResponse.

Determine if all objects for the current request/response should be ignored or not. Messages will stop being ignored the next time isContentMessage(Object) returns true.

Parameters
msg:Object

The return value from newContinueResponse(Object, int, ChannelPipeline).

Returns:boolean

true if all objects for the current request/response should be ignored or not. false otherwise.

Annotations
@Override
isAggregatedback to summary
protected boolean isAggregated(WebSocketFrame msg) throws Exception

Implements abstract io.netty.handler.codec.MessageAggregator.isAggregated.

Doc from io.netty.handler.codec.MessageAggregator.isAggregated.

Returns true if and only if the specified message is already aggregated. If this method returns true, this handler will simply forward the message to the next handler as-is.

Annotations
@Override
isContentLengthInvalidback to summary
protected boolean isContentLengthInvalid(WebSocketFrame start, int maxContentLength)

Implements abstract io.netty.handler.codec.MessageAggregator.isContentLengthInvalid.

Doc from io.netty.handler.codec.MessageAggregator.isContentLengthInvalid.

Determine if the message start's content length is known, and if it greater than maxContentLength.

Parameters
start:WebSocketFrame

The message which may indicate the content length.

maxContentLength:int

The maximum allowed content length.

Returns:boolean

true if the message start's content length is known, and if it greater than maxContentLength. false otherwise.

Annotations
@Override
isContentMessageback to summary
protected boolean isContentMessage(WebSocketFrame msg) throws Exception

Implements abstract io.netty.handler.codec.MessageAggregator.isContentMessage.

Doc from io.netty.handler.codec.MessageAggregator.isContentMessage.

Returns true if and only if the specified message is a content message. Typically, this method is implemented as a single return statement with instanceof: 

return msg instanceof MyContentMessage;
Annotations
@Override
isLastContentMessageback to summary
protected boolean isLastContentMessage(ContinuationWebSocketFrame msg) throws Exception

Implements abstract io.netty.handler.codec.MessageAggregator.isLastContentMessage.

Doc from io.netty.handler.codec.MessageAggregator.isLastContentMessage.

Returns true if and only if the specified message is the last content message. Typically, this method is implemented as a single return statement with instanceof: 

return msg instanceof MyLastContentMessage;
or with instanceof and boolean field check: 
return msg instanceof MyContentMessage && msg.isLastFragment();
Annotations
@Override
isStartMessageback to summary
protected boolean isStartMessage(WebSocketFrame msg) throws Exception

Implements abstract io.netty.handler.codec.MessageAggregator.isStartMessage.

Doc from io.netty.handler.codec.MessageAggregator.isStartMessage.

Returns true if and only if the specified message is a start message. Typically, this method is implemented as a single return statement with instanceof: 

return msg instanceof MyStartMessage;
Annotations
@Override
newContinueResponseback to summary
protected Object newContinueResponse(WebSocketFrame start, int maxContentLength, ChannelPipeline pipeline)

Implements abstract io.netty.handler.codec.MessageAggregator.newContinueResponse.

Doc from io.netty.handler.codec.MessageAggregator.newContinueResponse.

Returns the 'continue response' for the specified start message if necessary. For example, this method is useful to handle an HTTP 100-continue header.

Returns:Object

the 'continue response', or null if there's no message to send

Annotations
@Override