Class Message


  • public class Message
    extends java.lang.Object
    • Field Detail

      • HEADER_DESTINATION

        public static final java.lang.String HEADER_DESTINATION
        See Also:
        Constant Field Values
      • HEADER_TRANSACTION

        public static final java.lang.String HEADER_TRANSACTION
        See Also:
        Constant Field Values
      • HEADER_RECEIPT_ID

        public static final java.lang.String HEADER_RECEIPT_ID
        See Also:
        Constant Field Values
      • HEADER_CONTENT_LENGTH

        public static final java.lang.String HEADER_CONTENT_LENGTH
        See Also:
        Constant Field Values
      • HEADER_CONTENT_TYPE

        public static final java.lang.String HEADER_CONTENT_TYPE
        See Also:
        Constant Field Values
      • HEADER_HEART_BEAT

        public static final java.lang.String HEADER_HEART_BEAT
        See Also:
        Constant Field Values
      • HEADER_CORRELATION_ID

        public static final java.lang.String HEADER_CORRELATION_ID
        See Also:
        Constant Field Values
      • HEARTBEAT_FRAME

        public static final byte[] HEARTBEAT_FRAME
      • LOG

        private static final org.slf4j.Logger LOG
      • command

        private java.lang.String command
      • headers

        private java.util.Map<java.lang.String,​java.lang.String> headers
      • content

        private byte[] content
    • Constructor Detail

      • Message

        public Message()
    • Method Detail

      • withHeader

        public Message withHeader​(java.lang.String key,
                                  java.lang.String value)
      • withHeaders

        public Message withHeaders​(java.util.Map<java.lang.String,​java.lang.String> headers)
      • withContent

        public Message withContent​(byte[] content)
      • withCorrelationId

        public Message withCorrelationId()
      • withAdditionalContent

        public Message withAdditionalContent​(byte[] additional)
      • subscribe

        public Message subscribe()
      • unsubscribe

        public Message unsubscribe()
      • disconnect

        public Message disconnect()
      • connect

        public Message connect()
      • receipt

        public Message receipt()
      • connected

        public Message connected()
      • message

        public Message message()
      • setCommand

        private Message setCommand​(java.lang.String command)
      • build

        public byte[] build()
      • getCommand

        public java.lang.String getCommand()
      • getHeaders

        public java.util.Map<java.lang.String,​java.lang.String> getHeaders()
      • getContent

        public byte[] getContent()
      • getContent

        private static byte[] getContent​(byte[] array,
                                         java.lang.String[] message,
                                         int lineNumber)
      • getEncoding

        public java.nio.charset.Charset getEncoding()
      • getContentLength

        public int getContentLength()
      • trimEndOfMessage

        public void trimEndOfMessage()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object