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)
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 |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AmqpReader
public AmqpReader()
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