Class StompSubframeEncoder

    • Field Detail

      • ESCAPE_HEADER_KEY_CACHE_LIMIT

        private static final int ESCAPE_HEADER_KEY_CACHE_LIMIT
        See Also:
        Constant Field Values
      • ESCAPE_HEADER_KEY_CACHE

        private static final FastThreadLocal<java.util.LinkedHashMap<java.lang.CharSequence,​java.lang.CharSequence>> ESCAPE_HEADER_KEY_CACHE
    • Constructor Detail

      • StompSubframeEncoder

        public StompSubframeEncoder()
    • Method Detail

      • convertFullFrame

        protected java.lang.Object convertFullFrame​(StompFrame original,
                                                    ByteBuf encoded)
        An extension method to convert a STOMP encoded buffer to a different message type based on an original StompFrame full frame.

        By default an encoded buffer is returned as is.

      • convertHeadersSubFrame

        protected java.lang.Object convertHeadersSubFrame​(StompHeadersSubframe original,
                                                          ByteBuf encoded)
        An extension method to convert a STOMP encoded buffer to a different message type based on an original StompHeadersSubframe headers sub frame.

        By default an encoded buffer is returned as is.

      • convertContentSubFrame

        protected java.lang.Object convertContentSubFrame​(StompContentSubframe original,
                                                          ByteBuf encoded)
        An extension method to convert a STOMP encoded buffer to a different message type based on an original StompHeadersSubframe content sub frame.

        By default an encoded buffer is returned as is.

      • headersSubFrameSize

        protected int headersSubFrameSize​(StompHeadersSubframe headersSubframe)
        Returns a heuristic size for headers (32 bytes per header line) + (2 bytes for colon and eol) + (additional command buffer).
      • shouldEscape

        private static boolean shouldEscape​(StompCommand command)
      • escape

        private static java.lang.CharSequence escape​(java.lang.CharSequence input)