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