Package com.rabbitmq.client.impl

Class MethodArgumentReader

  • public class MethodArgumentReader
extends java.lang.Object
    Parses AMQP wire-protocol Method arguments from a DataInputStream. Methods on this object are usually called from generated code.

    • Field Summary

      Fields 
      Modifier and Type Field Description
      private int bits
      If we are reading one or more bits, holds the current packed collection of bits
      private ValueReader in
      The stream we are reading from.
      private int nextBitMask
      If we are reading one or more bits, keeps track of which bit position we will read from next.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      private void clearBits()
      Resets the bit group accumulator variables when some non-bit argument value is to be read.
      boolean readBit()
      Public API - reads a bit/boolean argument.
      int readLong()
      Public API - reads an integer argument.
      long readLonglong()
      Public API - reads a long integer argument.
      LongString readLongstr()
      Public API - reads a long string argument.
      int readOctet()
      Public API - reads an octet argument.
      int readShort()
      Public API - reads a short integer argument.
      java.lang.String readShortstr()
      Public API - reads a short string argument.
      java.util.Map<java.lang.String,​java.lang.Object> readTable()
      Public API - reads a table argument.
      java.util.Date readTimestamp()
      Public API - reads an timestamp argument.

      • 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
        The stream we are reading from.

      • bits

        private int bits
        If we are reading one or more bits, holds the current packed collection of bits

      • nextBitMask

        private int nextBitMask
        If we are reading one or more bits, keeps track of which bit position we will read from next. (reading least to most significant order)

    • Constructor Detail

      • MethodArgumentReader

        public MethodArgumentReader​(ValueReader in)
        Construct a MethodArgumentReader from the given ValueReader.

    • Method Detail

      • clearBits

        private void clearBits()
        Resets the bit group accumulator variables when some non-bit argument value is to be read.

      • readShortstr

        public final java.lang.String readShortstr()
                                    throws java.io.IOException
        Public API - reads a short string argument.
        Throws:
        java.io.IOException

      • readLongstr

        public final LongString readLongstr()
                             throws java.io.IOException
        Public API - reads a long string argument.
        Throws:
        java.io.IOException

      • readShort

        public final int readShort()
                    throws java.io.IOException
        Public API - reads a short integer argument.
        Throws:
        java.io.IOException

      • readLong

        public final int readLong()
                   throws java.io.IOException
        Public API - reads an integer argument.
        Throws:
        java.io.IOException

      • readLonglong

        public final long readLonglong()
                        throws java.io.IOException
        Public API - reads a long integer argument.
        Throws:
        java.io.IOException

      • readBit

        public final boolean readBit()
                      throws java.io.IOException
        Public API - reads a bit/boolean argument.
        Throws:
        java.io.IOException

      • readTable

        public final java.util.Map<java.lang.String,​java.lang.Object> readTable()
                                                                       throws java.io.IOException
        Public API - reads a table argument.
        Throws:
        java.io.IOException

      • readOctet

        public final int readOctet()
                    throws java.io.IOException
        Public API - reads an octet argument.
        Throws:
        java.io.IOException

      • readTimestamp

        public final java.util.Date readTimestamp()
                                   throws java.io.IOException
        Public API - reads an timestamp argument.
        Throws:
        java.io.IOException