com.caucho.amqp.io
Class AmqpAbstractComposite

java.lang.Object
  extended by com.caucho.amqp.io.AmqpAbstractPacket
      extended by 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
AmqpAbstractComposite()
           
 
Method Summary
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