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

Fields

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

Constructor Summary

Constructors

Constructor and Description
FrameTransfer()

Method Summary

Modifier and Type	Method and Description
FrameTransfer	createInstance()
long	getDeliveryId()
DeliveryState	getDeliveryState()
byte[]	getDeliveryTag()
long	getDescriptorCode()
int	getHandle()
int	getMessageFormat()
FrameAttach.ReceiverSettleMode	getReceiverSettleMode()
void	invoke(AmqpReader ain, AmqpFrameHandler handler)
boolean	isAborted()
boolean	isBatchable()
boolean	isMore()
boolean	isResume()
boolean	isSettled()
void	readBody(AmqpReader in, int count)
void	setDeliveryId(long deliveryId)
void	setHandle(int handle)
void	setSettled(boolean isSettled)
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

Field Detail

CODE

public static final int CODE

See Also:

Constant Field Values

Constructor Detail

FrameTransfer

public FrameTransfer()

Method Detail

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