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

Fields

Modifier and Type	Field and Description
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

Constructors

Constructor and Description
FrameBegin()

Method Summary

Modifier and Type	Method and Description
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