com.caucho.amqp.io
Class LinkSource

java.lang.Object
  extended by com.caucho.amqp.io.AmqpAbstractPacket
      extended by com.caucho.amqp.io.AmqpAbstractComposite
          extended by com.caucho.amqp.io.LinkSource
All Implemented Interfaces:
AmqpConstants

public class LinkSource
extends AmqpAbstractComposite

Describes the source node of a link


Nested Class Summary
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
LinkSource()
           
 
Method Summary
 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