com.caucho.amqp.io
Class FrameDisposition
java.lang.Object
com.caucho.amqp.io.AmqpAbstractPacket
com.caucho.amqp.io.AmqpAbstractComposite
com.caucho.amqp.io.AmqpAbstractFrame
com.caucho.amqp.io.FrameDisposition
- All Implemented Interfaces:
- AmqpConstants
public class FrameDisposition
- extends AmqpAbstractFrame
AMQP link flow
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 |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
FrameDisposition
public FrameDisposition()
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