com.caucho.amqp.io

Class AmqpReader

java.lang.Object

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

Constructors

Constructor and Description
AmqpReader()

Method Summary

Modifier and Type	Method and Description
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