com.caucho.amqp.io

Class AmqpAbstractComposite

java.lang.Object

com.caucho.amqp.io.AmqpAbstractPacket

com.caucho.amqp.io.AmqpAbstractComposite

All Implemented Interfaces:

AmqpConstants

Direct Known Subclasses:

AmqpAbstractFrame, AmqpError, DeliveryState, LinkSource, LinkTarget, MessageHeader, MessageProperties, XaDischarge

public abstract class AmqpAbstractComposite
extends AmqpAbstractPacket

AMQP composite list writer

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
AmqpAbstractComposite()

Method Summary

Modifier and Type	Method and Description
protected abstract long	getDescriptorCode()
void	read(AmqpReader in)
protected abstract void	readBody(AmqpReader in, int count)
void	readValue(AmqpReader in)
void	write(AmqpWriter out)
protected abstract int	writeBody(AmqpWriter out)

Methods inherited from class com.caucho.amqp.io.AmqpAbstractPacket

createInstance

Methods inherited from class java.lang.Object

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

Constructor Detail

AmqpAbstractComposite

public AmqpAbstractComposite()

Method Detail

getDescriptorCode

protected abstract long getDescriptorCode()

Overrides:

getDescriptorCode in class AmqpAbstractPacket

writeBody

protected abstract int writeBody(AmqpWriter out)
                          throws java.io.IOException

Throws:

java.io.IOException

readBody

protected abstract void readBody(AmqpReader in,
                                 int count)
                          throws java.io.IOException

Throws:

java.io.IOException

write

public final void write(AmqpWriter out)
                 throws java.io.IOException

Overrides:

write in class AmqpAbstractPacket

Throws:

java.io.IOException

read

public void read(AmqpReader in)
          throws java.io.IOException

Overrides:

read in class AmqpAbstractPacket

Throws:

java.io.IOException

readValue

public void readValue(AmqpReader in)
               throws java.io.IOException

Overrides:

readValue in class AmqpAbstractPacket

Throws:

java.io.IOException