com.caucho.amqp.io
Class FrameDisposition

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

public class FrameDisposition
extends AmqpAbstractFrame

AMQP link flow


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
FrameDisposition()
           
 
Method Summary
 FrameDisposition createInstance()
           
 long getDescriptorCode()
           
 long getFirst()
           
 long getLast()
           
 FrameAttach.Role getRole()
           
 DeliveryState getState()
           
 void invoke(AmqpReader fin, AmqpFrameHandler receiver)
           
 boolean isBatchable()
           
 boolean isSettled()
           
 void readBody(AmqpReader in, int count)
           
 void setFirst(long first)
           
 void setLast(long last)
           
 void setRole(FrameAttach.Role role)
           
 void setSettled(boolean isSettled)
           
 void setState(DeliveryState state)
          Sets the delivery state.
 java.lang.String toString()
           
 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, wait, wait, wait
 

Constructor Detail

FrameDisposition

public FrameDisposition()
Method Detail

setRole

public void setRole(FrameAttach.Role role)

getRole

public FrameAttach.Role getRole()

setFirst

public void setFirst(long first)

getFirst

public long getFirst()

setLast

public void setLast(long last)

getLast

public long getLast()

isSettled

public boolean isSettled()

setSettled

public void setSettled(boolean isSettled)

getState

public DeliveryState getState()

setState

public void setState(DeliveryState state)
Sets the delivery state.


isBatchable

public boolean isBatchable()

getDescriptorCode

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

createInstance

public FrameDisposition createInstance()
Overrides:
createInstance in class AmqpAbstractPacket

invoke

public void invoke(AmqpReader fin,
                   AmqpFrameHandler receiver)
            throws java.io.IOException
Overrides:
invoke in class AmqpAbstractFrame
Throws:
java.io.IOException

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

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object