com.caucho.amqp.io
Class DeliveryModified

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.DeliveryModified
All Implemented Interfaces:
AmqpConstants

public class DeliveryModified
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
DeliveryModified()
           
 
Method Summary
 DeliveryModified createInstance()
           
 long getDescriptorCode()
           
 boolean isDeliveryFailed()
           
 boolean isUndeliverableHere()
           
 void readBody(AmqpReader in, int count)
           
 void setDeliveryFailed(boolean isFailed)
           
 void setUndeliverableHere(boolean isUndeliverable)
           
 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 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DeliveryModified

public DeliveryModified()
Method Detail

isDeliveryFailed

public boolean isDeliveryFailed()

setDeliveryFailed

public void setDeliveryFailed(boolean isFailed)

isUndeliverableHere

public boolean isUndeliverableHere()

setUndeliverableHere

public void setUndeliverableHere(boolean isUndeliverable)

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

createInstance

public DeliveryModified createInstance()
Overrides:
createInstance in class AmqpAbstractPacket

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