com.caucho.amqp.io

Class DeliveryReceived

java.lang.Object

com.caucho.amqp.io.AmqpAbstractPacket

com.caucho.amqp.io.AmqpAbstractComposite

com.caucho.amqp.io.DeliveryState

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

Constructors

Constructor and Description
DeliveryReceived()

Method Summary

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