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

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

Constructors

Constructor and Description
FrameDisposition()

Method Summary

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