com.caucho.amqp.io

Class FrameFlow

java.lang.Object

com.caucho.amqp.io.AmqpAbstractPacket

com.caucho.amqp.io.AmqpAbstractComposite

com.caucho.amqp.io.AmqpAbstractFrame

com.caucho.amqp.io.FrameFlow

All Implemented Interfaces:

AmqpConstants

public class FrameFlow
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
FrameFlow()

Method Summary

Modifier and Type	Method and Description
FrameFlow	createInstance()
int	getAvailable()
long	getDeliveryCount()
long	getDescriptorCode()
int	getHandle()
int	getIncomingWindow()
int	getLinkCredit()
long	getNextIncomingId()
long	getNextOutgoingId()
int	getOutgoingWindow()
java.util.Map<java.lang.String,?>	getProperties()
void	invoke(AmqpReader ain, AmqpFrameHandler receiver)
boolean	isDrain()
boolean	isEcho()
void	readBody(AmqpReader in, int count)
void	setAvailable(int available)
void	setDeliveryCount(long deliveryCount)
void	setHandle(int handle)
void	setLinkCredit(int linkCredit)
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

Constructor Detail

FrameFlow

public FrameFlow()

Method Detail

getNextIncomingId

public long getNextIncomingId()

getIncomingWindow

public int getIncomingWindow()

getNextOutgoingId

public long getNextOutgoingId()

getOutgoingWindow

public int getOutgoingWindow()

getHandle

public int getHandle()

setHandle

public void setHandle(int handle)

setDeliveryCount

public void setDeliveryCount(long deliveryCount)

getDeliveryCount

public long getDeliveryCount()

getLinkCredit

public int getLinkCredit()

setLinkCredit

public void setLinkCredit(int linkCredit)

getAvailable

public int getAvailable()

setAvailable

public void setAvailable(int available)

isDrain

public boolean isDrain()

isEcho

public boolean isEcho()

getProperties

public java.util.Map<java.lang.String,?> getProperties()

getDescriptorCode

public long getDescriptorCode()

Specified by:

getDescriptorCode in class AmqpAbstractComposite

createInstance

public FrameFlow createInstance()

Overrides:

createInstance in class AmqpAbstractPacket

invoke

public void invoke(AmqpReader ain,
                   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