com.caucho.amqp.io

Class LinkSource

java.lang.Object

com.caucho.amqp.io.AmqpAbstractPacket

com.caucho.amqp.io.AmqpAbstractComposite

com.caucho.amqp.io.LinkSource

All Implemented Interfaces:

AmqpConstants

public class LinkSource
extends AmqpAbstractComposite

Describes the source node of a link

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LinkSource.Durability
static class	LinkSource.ExpiryPolicy

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

Constructors

Constructor and Description
LinkSource()

Method Summary

Modifier and Type	Method and Description
LinkSource	createInstance()
java.lang.String	getAddress()
java.util.List<java.lang.String>	getCapabilities()
java.lang.String	getDefaultOutcome()
long	getDescriptorCode()
DistributionMode	getDistributionMode()
LinkSource.Durability	getDurable()
java.util.Map<java.lang.String,java.lang.Object>	getDynamicNodeProperties()
LinkSource.ExpiryPolicy	getExpiryPolicy()
java.util.Map<java.lang.String,?>	getFilter()
java.util.List<java.lang.String>	getOutcomes()
long	getTimeout()
boolean	isDynamic()
void	readBody(AmqpReader in, int count)
void	setAddress(java.lang.String address)
void	setDistributionMode(DistributionMode distMode)
void	setDynamicNodeProperties(java.util.Map<java.lang.String,java.lang.Object> props)
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

LinkSource

public LinkSource()

Method Detail

getAddress

public java.lang.String getAddress()

setAddress

public void setAddress(java.lang.String address)

getDurable

public LinkSource.Durability getDurable()

getExpiryPolicy

public LinkSource.ExpiryPolicy getExpiryPolicy()

getTimeout

public long getTimeout()

isDynamic

public boolean isDynamic()

setDynamicNodeProperties

public void setDynamicNodeProperties(java.util.Map<java.lang.String,java.lang.Object> props)

getDynamicNodeProperties

public java.util.Map<java.lang.String,java.lang.Object> getDynamicNodeProperties()

getDistributionMode

public DistributionMode getDistributionMode()

setDistributionMode

public void setDistributionMode(DistributionMode distMode)

getFilter

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

getDefaultOutcome

public java.lang.String getDefaultOutcome()

getOutcomes

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

getCapabilities

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

getDescriptorCode

public long getDescriptorCode()

Specified by:

getDescriptorCode in class AmqpAbstractComposite

createInstance

public LinkSource createInstance()

Overrides:

createInstance in class AmqpAbstractPacket

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