com.caucho.amqp.io
Class FrameTransfer
java.lang.Object
com.caucho.amqp.io.AmqpAbstractPacket
com.caucho.amqp.io.AmqpAbstractComposite
com.caucho.amqp.io.AmqpAbstractFrame
com.caucho.amqp.io.FrameTransfer
- All Implemented Interfaces:
- AmqpConstants
public class FrameTransfer
- extends AmqpAbstractFrame
AMQP session-begin frame
Field Summary |
static int |
CODE
|
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, toString, wait, wait, wait |
CODE
public static final int CODE
- See Also:
- Constant Field Values
FrameTransfer
public FrameTransfer()
getHandle
public int getHandle()
setHandle
public void setHandle(int handle)
getDeliveryId
public long getDeliveryId()
setDeliveryId
public void setDeliveryId(long deliveryId)
getDeliveryTag
public byte[] getDeliveryTag()
getMessageFormat
public int getMessageFormat()
isSettled
public boolean isSettled()
setSettled
public void setSettled(boolean isSettled)
isMore
public boolean isMore()
getReceiverSettleMode
public FrameAttach.ReceiverSettleMode getReceiverSettleMode()
getDeliveryState
public DeliveryState getDeliveryState()
isResume
public boolean isResume()
isAborted
public boolean isAborted()
isBatchable
public boolean isBatchable()
getDescriptorCode
public long getDescriptorCode()
- Specified by:
getDescriptorCode
in class AmqpAbstractComposite
createInstance
public FrameTransfer createInstance()
- Overrides:
createInstance
in class AmqpAbstractPacket
invoke
public void invoke(AmqpReader ain,
AmqpFrameHandler handler)
throws java.io.IOException
- Overrides:
invoke
in class AmqpAbstractFrame
- Throws:
java.io.IOException
writeBody
public int writeBody(AmqpWriter out)
throws java.io.IOException
- Specified by:
writeBody
in class AmqpAbstractComposite
- 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