Class StompSubframeDecoder

  • All Implemented Interfaces:
    ChannelHandler, ChannelInboundHandler

    public class StompSubframeDecoder
    extends ReplayingDecoder<StompSubframeDecoder.State>
    Decodes ByteBufs into StompHeadersSubframes and StompContentSubframes.

    Parameters to control memory consumption:

    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 StompContentSubframes whose length is maxChunkSize at maximum.

    Chunked Content

    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 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)