Package com.rabbitmq.client.impl

Class ContentHeaderPropertyReader

  • public class ContentHeaderPropertyReader
extends java.lang.Object
    Parses an AMQP wire-protocol ContentHeader from a DataInputStream. Methods on this object are usually called from autogenerated code.

    • Field Summary

      Fields 
      Modifier and Type Field Description
      private int bitCount
      Current flag position counter
      private int flagWord
      Current field flag word
      private ValueReader in
      Stream we are reading from

    • Constructor Summary

      Constructors 
      Constructor Description
      ContentHeaderPropertyReader​(java.io.DataInputStream in)
      Protected API - Constructs a reader from the given input stream

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void finishPresence()  
      private boolean isContinuationBitSet()  
      void readFlagWord()  
      java.lang.Integer readLong()
      Reads and returns an AMQP integer content header field.
      java.lang.Long readLonglong()
      Reads and returns an AMQP long integer content header field.
      LongString readLongstr()
      Reads and returns an AMQP "long string" (binary) content header field.
      int readOctet()
      Reads and returns an AMQP octet content header field.
      boolean readPresence()  
      java.lang.Integer readShort()
      Reads and returns an AMQP short integer content header field.
      java.lang.String readShortstr()
      Reads and returns an AMQP short string content header field.
      java.util.Map<java.lang.String,​java.lang.Object> readTable()
      Reads and returns an AMQP table content header field.
      java.util.Date readTimestamp()
      Reads and returns an AMQP timestamp content header field.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Field Detail

      • in

        private final ValueReader in
        Stream we are reading from

      • flagWord

        private int flagWord
        Current field flag word

      • bitCount

        private int bitCount
        Current flag position counter

    • Constructor Detail

      • ContentHeaderPropertyReader

        public ContentHeaderPropertyReader​(java.io.DataInputStream in)
                            throws java.io.IOException
        Protected API - Constructs a reader from the given input stream
        Throws:
        java.io.IOException

    • Method Detail

      • isContinuationBitSet

        private boolean isContinuationBitSet()

      • readFlagWord

        public void readFlagWord()
                  throws java.io.IOException
        Throws:
        java.io.IOException

      • readPresence

        public boolean readPresence()
                     throws java.io.IOException
        Throws:
        java.io.IOException

      • finishPresence

        public void finishPresence()
                    throws java.io.IOException
        Throws:
        java.io.IOException

      • readShortstr

        public java.lang.String readShortstr()
                              throws java.io.IOException
        Reads and returns an AMQP short string content header field.
        Throws:
        java.io.IOException

      • readLongstr

        public LongString readLongstr()
                       throws java.io.IOException
        Reads and returns an AMQP "long string" (binary) content header field.
        Throws:
        java.io.IOException

      • readShort

        public java.lang.Integer readShort()
                            throws java.io.IOException
        Reads and returns an AMQP short integer content header field.
        Throws:
        java.io.IOException

      • readLong

        public java.lang.Integer readLong()
                           throws java.io.IOException
        Reads and returns an AMQP integer content header field.
        Throws:
        java.io.IOException

      • readLonglong

        public java.lang.Long readLonglong()
                            throws java.io.IOException
        Reads and returns an AMQP long integer content header field.
        Throws:
        java.io.IOException

      • readTable

        public java.util.Map<java.lang.String,​java.lang.Object> readTable()
                                                                 throws java.io.IOException
        Reads and returns an AMQP table content header field.
        Throws:
        java.io.IOException

      • readOctet

        public int readOctet()
              throws java.io.IOException
        Reads and returns an AMQP octet content header field.
        Throws:
        java.io.IOException

      • readTimestamp

        public java.util.Date readTimestamp()
                             throws java.io.IOException
        Reads and returns an AMQP timestamp content header field.
        Throws:
        java.io.IOException