com.caucho.amqp.io
Class AmqpReader

java.lang.Object
  extended by com.caucho.amqp.io.AmqpReader
All Implemented Interfaces:
AmqpConstants

public class AmqpReader
extends java.lang.Object
implements AmqpConstants

AMQP frame

 b0-b3 - size
 b4    - data offset
 b5    - type
 b6-b7 - extra (frame type specific, channel)
 


Field Summary
 
Fields inherited from interface com.caucho.amqp.io.AmqpConstants
E_ARRAY_1, E_ARRAY_4, E_BIN_1, E_BIN_4, E_BOOLEAN_1, E_BYTE_1, E_CHAR, E_DECIMAL_16, E_DECIMAL_4, E_DECIMAL_8, E_DESCRIPTOR, E_DOUBLE, E_FALSE, E_FLOAT, E_I0, E_INT_1, E_INT_4, E_L0, E_LIST_0, E_LIST_1, E_LIST_4, E_LONG_1, E_LONG_8, E_MAP_1, E_MAP_4, E_NULL, E_SHORT, E_SYMBOL_1, E_SYMBOL_4, E_TIMESTAMP, E_TRUE, E_UBYTE_1, E_UINT_1, E_UINT_4, E_ULONG_1, E_ULONG_8, E_USHORT, E_UTF8_1, E_UTF8_4, E_UUID, FT_CONN_CLOSE, FT_CONN_OPEN, FT_ERROR, FT_LINK_ATTACH, FT_LINK_DETACH, FT_LINK_FLOW, FT_MESSAGE_DISPOSITION, FT_MESSAGE_TRANSFER, FT_SESSION_END, FT_SESSION_OPEN, MIN_MAX_FRAME_SIZE, ST_MESSAGE_ACCEPTED, ST_MESSAGE_ANN, ST_MESSAGE_APP_PROPERTIES, ST_MESSAGE_DATA, ST_MESSAGE_DELIVERY_ANN, ST_MESSAGE_FOOTER, ST_MESSAGE_HEADER, ST_MESSAGE_MODIFIED, ST_MESSAGE_PROPERTIES, ST_MESSAGE_RECEIVED, ST_MESSAGE_REJECTED, ST_MESSAGE_RELEASED, ST_MESSAGE_SEQUENCE, ST_MESSAGE_SOURCE, ST_MESSAGE_TARGET, ST_MESSAGE_VALUE, ST_NODE_DELETE_ON_CLOSE, ST_NODE_DELETE_ON_NO_LINK, ST_NODE_DELETE_ON_NO_LINK_OR_MESSAGES, ST_NODE_DELETE_ON_NO_MESSAGES, ST_SASL_CHALLENGE, ST_SASL_INIT, ST_SASL_MECHANISMS, ST_SASL_OUTCOME, ST_SASL_RESPONSE, ST_XA_COORDINATOR, ST_XA_DECLARE, ST_XA_DECLARED, ST_XA_DISCHARGE, ST_XA_STATE
 
Constructor Summary
AmqpReader()
           
 
Method Summary
 void endList()
           
 int getFrameAvailable()
           
 void init(java.io.InputStream is)
           
 boolean isNull()
           
 long peekDescriptor()
           
 int read()
           
 int read(byte[] buffer, int offset, int length)
           
 java.util.List<?> readArray()
           
 byte[] readBinary()
           
 boolean readBoolean()
           
 long readDescriptor()
           
 java.util.Map<java.lang.String,java.lang.Object> readFieldMap()
           
 int readInt()
           
 java.util.List<?> readList()
           
 long readLong()
           
 java.util.Map<?,?> readMap()
           
 java.lang.Object readObject()
           
<T extends AmqpAbstractPacket>
T
readObject(java.lang.Class<T> type)
           
 java.lang.Object readObject(long descriptor)
           
<T extends AmqpAbstractPacket>
T
readObject(long descriptor, java.lang.Class<T> type)
           
 java.lang.String readString()
           
 java.lang.String readSymbol()
           
 java.util.List<java.lang.String> readSymbolArray()
           
 int startList()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AmqpReader

public AmqpReader()
Method Detail

init

public void init(java.io.InputStream is)

getFrameAvailable

public int getFrameAvailable()

isNull

public boolean isNull()

read

public int read()
         throws java.io.IOException
Throws:
java.io.IOException

peekDescriptor

public long peekDescriptor()
                    throws java.io.IOException
Throws:
java.io.IOException

read

public int read(byte[] buffer,
                int offset,
                int length)
         throws java.io.IOException
Throws:
java.io.IOException

readBoolean

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

readInt

public int readInt()
            throws java.io.IOException
Throws:
java.io.IOException

readLong

public long readLong()
              throws java.io.IOException
Throws:
java.io.IOException

readSymbolArray

public java.util.List<java.lang.String> readSymbolArray()
                                                 throws java.io.IOException
Throws:
java.io.IOException

readSymbol

public java.lang.String readSymbol()
                            throws java.io.IOException
Throws:
java.io.IOException

readBinary

public byte[] readBinary()
                  throws java.io.IOException
Throws:
java.io.IOException

readString

public java.lang.String readString()
                            throws java.io.IOException
Throws:
java.io.IOException

readDescriptor

public long readDescriptor()
                    throws java.io.IOException
Throws:
java.io.IOException

readObject

public <T extends AmqpAbstractPacket> T readObject(java.lang.Class<T> type)
                                        throws java.io.IOException
Throws:
java.io.IOException

readObject

public java.lang.Object readObject(long descriptor)
                            throws java.io.IOException
Throws:
java.io.IOException

readObject

public <T extends AmqpAbstractPacket> T readObject(long descriptor,
                                                   java.lang.Class<T> type)
                                        throws java.io.IOException
Throws:
java.io.IOException

readObject

public java.lang.Object readObject()
                            throws java.io.IOException
Throws:
java.io.IOException

readList

public java.util.List<?> readList()
                           throws java.io.IOException
Throws:
java.io.IOException

startList

public int startList()
              throws java.io.IOException
Throws:
java.io.IOException

endList

public void endList()

readArray

public java.util.List<?> readArray()
                            throws java.io.IOException
Throws:
java.io.IOException

readFieldMap

public java.util.Map<java.lang.String,java.lang.Object> readFieldMap()
                                                              throws java.io.IOException
Throws:
java.io.IOException

readMap

public java.util.Map<?,?> readMap()
                           throws java.io.IOException
Throws:
java.io.IOException