com.caucho.amqp.io
Class FrameFlow

java.lang.Object
  extended by com.caucho.amqp.io.AmqpAbstractPacket
      extended by com.caucho.amqp.io.AmqpAbstractComposite
          extended by com.caucho.amqp.io.AmqpAbstractFrame
              extended by 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
FrameFlow()
           
 
Method Summary
 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