com.caucho.amqp.io
Class FrameBegin

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.FrameBegin
All Implemented Interfaces:
AmqpConstants

public class FrameBegin
extends AmqpAbstractFrame

AMQP session-begin frame


Field Summary
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
FrameBegin()
           
 
Method Summary
 FrameBegin createInstance()
           
 long getDescriptorCode()
           
 java.util.List<java.lang.String> getDesiredCapabilities()
           
 int getHandleMax()
           
 int getIncomingWindow()
           
 long getNextOutgoingId()
           
 java.util.List<java.lang.String> getOfferedCapabilities()
           
 int getOutgoingWindow()
           
 java.util.Map<java.lang.String,?> getProperties()
           
 int getRemoteChannel()
           
 void invoke(AmqpReader ain, AmqpFrameHandler receiver)
           
 void readBody(AmqpReader in, int count)
           
 void setHandleMax(int max)
           
 void setIncomingWindow(int window)
           
 void setNextOutgoingId(long id)
           
 void setOutgoingWindow(int window)
           
 void setRemoteChannel(int channel)
           
 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
 

Field Detail

CODE

public static final int CODE
See Also:
Constant Field Values
Constructor Detail

FrameBegin

public FrameBegin()
Method Detail

setRemoteChannel

public void setRemoteChannel(int channel)

getRemoteChannel

public int getRemoteChannel()

setNextOutgoingId

public void setNextOutgoingId(long id)

getNextOutgoingId

public long getNextOutgoingId()

setIncomingWindow

public void setIncomingWindow(int window)

getIncomingWindow

public int getIncomingWindow()

setOutgoingWindow

public void setOutgoingWindow(int window)

getOutgoingWindow

public int getOutgoingWindow()

setHandleMax

public void setHandleMax(int max)

getHandleMax

public int getHandleMax()

getOfferedCapabilities

public java.util.List<java.lang.String> getOfferedCapabilities()

getDesiredCapabilities

public java.util.List<java.lang.String> getDesiredCapabilities()

getProperties

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

getDescriptorCode

public long getDescriptorCode()
Specified by:
getDescriptorCode in class AmqpAbstractComposite

createInstance

public FrameBegin 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

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

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object