org.jboss.netty.handler.codec.http.websocketx

Class WebSocketFrameAggregator

java.lang.Object

org.jboss.netty.handler.codec.oneone.OneToOneDecoder

org.jboss.netty.handler.codec.http.websocketx.WebSocketFrameAggregator

All Implemented Interfaces:

ChannelHandler, ChannelUpstreamHandler

public class WebSocketFrameAggregator
extends OneToOneDecoder

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.

Nested Class Summary

Nested classes/interfaces inherited from interface org.jboss.netty.channel.ChannelHandler

ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
private WebSocketFrame	currentFrame
private int	maxFrameSize
private boolean	tooLongFrameFound

Constructor Summary

Constructors

Constructor and Description
WebSocketFrameAggregator(int maxFrameSize) Construct a new instance

Method Summary

Modifier and Type	Method and Description
protected java.lang.Object	decode(ChannelHandlerContext ctx, Channel channel, java.lang.Object message) Transforms the specified received message into another message and return the transformed message.

Methods inherited from class org.jboss.netty.handler.codec.oneone.OneToOneDecoder

handleUpstream

Methods inherited from class java.lang.Object

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

Field Detail

maxFrameSize

private final int maxFrameSize

currentFrame

private WebSocketFrame currentFrame

tooLongFrameFound

private boolean tooLongFrameFound

Constructor Detail

WebSocketFrameAggregator

public WebSocketFrameAggregator(int maxFrameSize)

Construct a new instance

Parameters:

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

Method Detail

decode

protected java.lang.Object decode(ChannelHandlerContext ctx,
                                  Channel channel,
                                  java.lang.Object message)
                           throws java.lang.Exception

Description copied from class: OneToOneDecoder

Transforms the specified received message into another message and return the transformed message. Return null if the received message is supposed to be discarded.

Specified by:

decode in class OneToOneDecoder

Throws:

java.lang.Exception