com.caucho.amqp.io
Class DeliveryReceived

java.lang.Object
  extended by com.caucho.amqp.io.AmqpAbstractPacket
      extended by com.caucho.amqp.io.AmqpAbstractComposite
          extended by com.caucho.amqp.io.DeliveryState
              extended by com.caucho.amqp.io.DeliveryReceived
All Implemented Interfaces:
AmqpConstants

public class DeliveryReceived
extends DeliveryState

AMQP delivery received


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
DeliveryReceived()
           
 
Method Summary
 long getDescriptorCode()
           
 long getSectionNumber()
           
 long getSectionOffset()
           
 void readBody(AmqpReader in, int count)
           
 void setSectionNumber(long sectionNumber)
           
 void setSectionOffset(long sectionOffset)
           
 void update(long xid, DeliveryNode node)
          Called on a disposition update.
 int writeBody(AmqpWriter out)
           
 
Methods inherited from class com.caucho.amqp.io.AmqpAbstractComposite
read, readValue, write
 
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

DeliveryReceived

public DeliveryReceived()
Method Detail

getSectionNumber

public long getSectionNumber()

setSectionNumber

public void setSectionNumber(long sectionNumber)

getSectionOffset

public long getSectionOffset()

setSectionOffset

public void setSectionOffset(long sectionOffset)

update

public void update(long xid,
                   DeliveryNode node)
Called on a disposition update.

Specified by:
update in class DeliveryState

getDescriptorCode

public long getDescriptorCode()
Specified by:
getDescriptorCode in class AmqpAbstractComposite

readBody

public void readBody(AmqpReader in,
                     int count)
              throws java.io.IOException
Specified by:
readBody in class AmqpAbstractComposite
Throws:
java.io.IOException

writeBody

public int writeBody(AmqpWriter out)
              throws java.io.IOException
Specified by:
writeBody in class AmqpAbstractComposite
Throws:
java.io.IOException