public class StompSubframeDecoder
extends io.netty.handler.codec.ReplayingDecoder<io.netty.handler.codec.stomp.StompSubframeDecoder.State>
ByteBuf
s into StompHeadersSubframe
s and StompContentSubframe
s.
maxLineLength
the maximum length of line - restricts length of command and header lines If the length of the
initial line exceeds this value, a TooLongFrameException
will be raised.
maxChunkSize
The 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 multiple StompContentSubframe
s whose length
is maxChunkSize
at maximum.
If the content of a stomp message is greater than maxChunkSize
the transfer encoding of the HTTP message is
'chunked', this decoder generates multiple StompContentSubframe
instances to avoid excessive memory
consumption. Note, that every message, even with no content decodes with LastStompContentSubframe
at the end
to simplify upstream message parsing.
Constructor and Description |
---|
StompSubframeDecoder() |
StompSubframeDecoder(boolean validateHeaders) |
StompSubframeDecoder(int maxLineLength,
int maxChunkSize) |
StompSubframeDecoder(int maxLineLength,
int maxChunkSize,
boolean validateHeaders) |
Modifier and Type | Method and Description |
---|---|
protected void |
decode(io.netty.channel.ChannelHandlerContext ctx,
io.netty.buffer.ByteBuf in,
List<Object> out) |
callDecode, checkpoint, checkpoint, state, state
actualReadableBytes, channelInactive, channelRead, channelReadComplete, decodeLast, discardSomeReadBytes, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode, userEventTriggered
channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught
ensureNotSharable, handlerAdded, isSharable
public StompSubframeDecoder()
public StompSubframeDecoder(boolean validateHeaders)
public StompSubframeDecoder(int maxLineLength, int maxChunkSize)
public StompSubframeDecoder(int maxLineLength, int maxChunkSize, boolean validateHeaders)
Copyright © 2008–2020 The Netty Project. All rights reserved.