com.caucho.amqp.io
Class FrameBegin
java.lang.Object
com.caucho.amqp.io.AmqpAbstractPacket
com.caucho.amqp.io.AmqpAbstractComposite
com.caucho.amqp.io.AmqpAbstractFrame
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 |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
CODE
public static final int CODE
- See Also:
- Constant Field Values
FrameBegin
public FrameBegin()
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