Package io.netty.handler.codec.stomp
Class StompSubframeDecoder
- java.lang.Object
-
- io.netty.channel.ChannelHandlerAdapter
-
- io.netty.channel.ChannelInboundHandlerAdapter
-
- io.netty.handler.codec.ByteToMessageDecoder
-
- io.netty.handler.codec.ReplayingDecoder<StompSubframeDecoder.State>
-
- io.netty.handler.codec.stomp.StompSubframeDecoder
-
- All Implemented Interfaces:
ChannelHandler,ChannelInboundHandler
public class StompSubframeDecoder extends ReplayingDecoder<StompSubframeDecoder.State>
DecodesByteBufs intoStompHeadersSubframes andStompContentSubframes.Parameters to control memory consumption:
maxLineLengththe maximum length of line - restricts length of command and header lines If the length of the initial line exceeds this value, aTooLongFrameExceptionwill be raised.
maxChunkSizeThe maximum length of the content or each chunk. If the content length (or the length of each chunk) exceeds this value, the content or chunk ill be split into multipleStompContentSubframes whose length ismaxChunkSizeat maximum.Chunked Content
If the content of a stomp message is greater than
maxChunkSizethe transfer encoding of the HTTP message is 'chunked', this decoder generates multipleStompContentSubframeinstances to avoid excessive memory consumption. Note, that every message, even with no content decodes withLastStompContentSubframeat the end to simplify upstream message parsing.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classStompSubframeDecoder.StateDeprecated.this should never be used by an user!-
Nested classes/interfaces inherited from class io.netty.handler.codec.ByteToMessageDecoder
ByteToMessageDecoder.Cumulator
-
Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler
ChannelHandler.Sharable
-
-
Field Summary
-
Fields inherited from class io.netty.handler.codec.ByteToMessageDecoder
COMPOSITE_CUMULATOR, MERGE_CUMULATOR
-
-
Constructor Summary
Constructors Constructor Description StompSubframeDecoder()StompSubframeDecoder(boolean validateHeaders)StompSubframeDecoder(int maxLineLength, int maxChunkSize)StompSubframeDecoder(int maxLineLength, int maxChunkSize, boolean validateHeaders)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voiddecode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out)Decode the from oneByteBufto an other.-
Methods inherited from class io.netty.handler.codec.ReplayingDecoder
callDecode, checkpoint, checkpoint, state, state
-
Methods inherited from class io.netty.handler.codec.ByteToMessageDecoder
actualReadableBytes, channelInactive, channelRead, channelReadComplete, decodeLast, discardSomeReadBytes, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode, userEventTriggered
-
Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter
channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught
-
Methods inherited from class io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, handlerAdded, isSharable
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface io.netty.channel.ChannelHandler
handlerAdded
-
-
-
-
Constructor Detail
-
StompSubframeDecoder
public StompSubframeDecoder()
-
StompSubframeDecoder
public StompSubframeDecoder(boolean validateHeaders)
-
StompSubframeDecoder
public StompSubframeDecoder(int maxLineLength, int maxChunkSize)
-
StompSubframeDecoder
public StompSubframeDecoder(int maxLineLength, int maxChunkSize, boolean validateHeaders)
-
-
Method Detail
-
decode
protected void decode(ChannelHandlerContext ctx, ByteBuf in, java.util.List<java.lang.Object> out) throws java.lang.Exception
Description copied from class:ByteToMessageDecoderDecode the from oneByteBufto an other. This method will be called till either the inputByteBufhas nothing to read when return from this method or till nothing was read from the inputByteBuf.- Specified by:
decodein classByteToMessageDecoder- Parameters:
ctx- theChannelHandlerContextwhich thisByteToMessageDecoderbelongs toin- theByteBuffrom which to read dataout- theListto which decoded messages should be added- Throws:
java.lang.Exception- is thrown if an error occurs
-
-