org.apache.qpid.client
Class AMQDestination

java.lang.Object
  extended by org.apache.qpid.client.AMQDestination
All Implemented Interfaces:
Destination, Referenceable
Direct Known Subclasses:
AMQAnyDestination, AMQHeadersExchange, AMQQueue, AMQTopic, AMQUndefinedDestination

public abstract class AMQDestination
extends Object
implements Destination, Referenceable


Nested Class Summary
static class AMQDestination.AddressOption
           
static class AMQDestination.Binding
           
static class AMQDestination.DestSyntax
           
 
Field Summary
protected  org.apache.qpid.messaging.Address _address
           
protected  int _addressType
           
protected  AddressHelper _addrHelper
           
protected  AMQDestination.AddressOption _assert
           
protected  AMQDestination.AddressOption _create
           
protected  AMQDestination.AddressOption _delete
           
protected  AMQDestination.DestSyntax _destSyntax
           
protected  org.apache.qpid.framing.AMQShortString _exchangeClass
           
protected  org.apache.qpid.framing.AMQShortString _exchangeName
           
protected  boolean _isAutoDelete
           
protected  boolean _isDurable
           
protected  boolean _isExclusive
           
protected  Link _link
           
protected  String _name
           
protected  Node _sourceNode
           
protected  String _subject
           
protected  Link _targetLink
           
protected  Node _targetNode
           
protected static AMQDestination.DestSyntax defaultDestSyntax
           
static int QUEUE_TYPE
           
static int TOPIC_TYPE
           
static int UNKNOWN_TYPE
           
 
Constructor Summary
protected AMQDestination(org.apache.qpid.messaging.Address address)
           
protected AMQDestination(org.apache.qpid.framing.AMQShortString exchangeName, org.apache.qpid.framing.AMQShortString exchangeClass, org.apache.qpid.framing.AMQShortString destinationName)
           
protected AMQDestination(org.apache.qpid.framing.AMQShortString exchangeName, org.apache.qpid.framing.AMQShortString exchangeClass, org.apache.qpid.framing.AMQShortString routingKey, org.apache.qpid.framing.AMQShortString queueName)
           
protected AMQDestination(org.apache.qpid.framing.AMQShortString exchangeName, org.apache.qpid.framing.AMQShortString exchangeClass, org.apache.qpid.framing.AMQShortString routingKey, org.apache.qpid.framing.AMQShortString queueName, org.apache.qpid.framing.AMQShortString[] bindingKeys)
           
protected AMQDestination(org.apache.qpid.framing.AMQShortString exchangeName, org.apache.qpid.framing.AMQShortString exchangeClass, org.apache.qpid.framing.AMQShortString routingKey, boolean isExclusive, boolean isAutoDelete, org.apache.qpid.framing.AMQShortString queueName)
           
protected AMQDestination(org.apache.qpid.framing.AMQShortString exchangeName, org.apache.qpid.framing.AMQShortString exchangeClass, org.apache.qpid.framing.AMQShortString routingKey, boolean isExclusive, boolean isAutoDelete, org.apache.qpid.framing.AMQShortString queueName, org.apache.qpid.framing.AMQShortString[] bindingKeys)
           
protected AMQDestination(org.apache.qpid.framing.AMQShortString exchangeName, org.apache.qpid.framing.AMQShortString exchangeClass, org.apache.qpid.framing.AMQShortString routingKey, boolean isExclusive, boolean isAutoDelete, org.apache.qpid.framing.AMQShortString queueName, boolean isDurable)
           
protected AMQDestination(org.apache.qpid.framing.AMQShortString exchangeName, org.apache.qpid.framing.AMQShortString exchangeClass, org.apache.qpid.framing.AMQShortString routingKey, boolean isExclusive, boolean isAutoDelete, org.apache.qpid.framing.AMQShortString queueName, boolean isDurable, org.apache.qpid.framing.AMQShortString[] bindingKeys)
           
protected AMQDestination(org.apache.qpid.framing.AMQShortString exchangeName, org.apache.qpid.framing.AMQShortString exchangeClass, org.apache.qpid.framing.AMQShortString routingKey, boolean isExclusive, boolean isAutoDelete, org.apache.qpid.framing.AMQShortString queueName, boolean isDurable, org.apache.qpid.framing.AMQShortString[] bindingKeys, boolean browseOnly)
           
protected AMQDestination(org.apache.qpid.url.BindingURL binding)
           
protected AMQDestination(String str)
           
 
Method Summary
 AMQDestination copyDestination()
           
static Destination createDestination(org.apache.qpid.url.BindingURL binding)
           
static Destination createDestination(byte[] byteEncodedDestination)
           
static Destination createDestination(String str)
           
 boolean equals(Object o)
           
 org.apache.qpid.messaging.Address getAddress()
           
 String getAddressName()
           
 int getAddressType()
           
 org.apache.qpid.framing.AMQShortString getAMQQueueName()
           
 AMQDestination.AddressOption getAssert()
           
 org.apache.qpid.framing.AMQShortString[] getBindingKeys()
           
 AMQDestination.AddressOption getCreate()
           
static AMQDestination.DestSyntax getDefaultDestSyntax()
           
 AMQDestination.AddressOption getDelete()
           
 AMQDestination.DestSyntax getDestSyntax()
           
static AMQDestination.DestSyntax getDestType(String str)
           
 org.apache.qpid.framing.AMQShortString getEncodedName()
           
 org.apache.qpid.framing.AMQShortString getExchangeClass()
           
 org.apache.qpid.framing.AMQShortString getExchangeName()
           
protected  void getInfoFromBindingURL(org.apache.qpid.url.BindingURL binding)
           
 Link getLink()
           
 String getQueueName()
           
 Reference getReference()
           
 org.apache.qpid.framing.AMQShortString getRoutingKey()
           
 Node getSourceNode()
           
 String getSubject()
           
 Node getTargetNode()
           
 int hashCode()
           
 boolean isAddressResolved()
           
 boolean isAutoDelete()
           
 boolean isBrowseOnly()
           
 boolean isCheckedForQueueBinding()
           
 boolean isDurable()
           
 boolean isExchangeExistsChecked()
           
 boolean isExclusive()
           
abstract  boolean isNameRequired()
           
 boolean isQueue()
           
 boolean isTopic()
           
 void rebuildTargetAndSourceNodes(int addressType)
           
protected  void setAddress(org.apache.qpid.messaging.Address addr)
           
 void setAddressName(String name)
           
 void setAddressResolved(boolean addressResolved)
           
 void setAddressType(int addressType)
           
 void setAssert(AMQDestination.AddressOption option)
           
protected  void setAutoDelete(boolean b)
           
 void setBrowseOnly(boolean b)
           
 void setCheckedForQueueBinding(boolean checkedForQueueBinding)
           
 void setCreate(AMQDestination.AddressOption option)
           
 void setDelete(AMQDestination.AddressOption option)
           
protected  void setDestSyntax(AMQDestination.DestSyntax syntax)
           
protected  void setDurable(boolean b)
           
 void setExchangeClass(org.apache.qpid.framing.AMQShortString type)
           
 void setExchangeExistsChecked(boolean exchangeExistsChecked)
           
 void setExchangeName(org.apache.qpid.framing.AMQShortString name)
           
 void setLink(Link link)
           
 void setQueueName(org.apache.qpid.framing.AMQShortString queueName)
           
 void setRoutingKey(org.apache.qpid.framing.AMQShortString rk)
           
 void setSourceNode(Node node)
           
 void setSubject(String subject)
           
 void setTargetNode(Node node)
           
static String stripSyntaxPrefix(String str)
           
 byte[] toByteEncoding()
           
 String toString()
           
 String toURL()
           
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Field Detail

_exchangeName

protected org.apache.qpid.framing.AMQShortString _exchangeName

_exchangeClass

protected org.apache.qpid.framing.AMQShortString _exchangeClass

_isDurable

protected boolean _isDurable

_isExclusive

protected boolean _isExclusive

_isAutoDelete

protected boolean _isAutoDelete

QUEUE_TYPE

public static final int QUEUE_TYPE
See Also:
Constant Field Values

TOPIC_TYPE

public static final int TOPIC_TYPE
See Also:
Constant Field Values

UNKNOWN_TYPE

public static final int UNKNOWN_TYPE
See Also:
Constant Field Values

defaultDestSyntax

protected static final AMQDestination.DestSyntax defaultDestSyntax

_destSyntax

protected AMQDestination.DestSyntax _destSyntax

_addrHelper

protected AddressHelper _addrHelper

_address

protected org.apache.qpid.messaging.Address _address

_addressType

protected int _addressType

_name

protected String _name

_subject

protected String _subject

_create

protected AMQDestination.AddressOption _create

_assert

protected AMQDestination.AddressOption _assert

_delete

protected AMQDestination.AddressOption _delete

_targetNode

protected Node _targetNode

_sourceNode

protected Node _sourceNode

_targetLink

protected Link _targetLink

_link

protected Link _link
Constructor Detail

AMQDestination

protected AMQDestination(org.apache.qpid.messaging.Address address)
                  throws Exception
Throws:
Exception

AMQDestination

protected AMQDestination(String str)
                  throws URISyntaxException
Throws:
URISyntaxException

AMQDestination

protected AMQDestination(org.apache.qpid.url.BindingURL binding)

AMQDestination

protected AMQDestination(org.apache.qpid.framing.AMQShortString exchangeName,
                         org.apache.qpid.framing.AMQShortString exchangeClass,
                         org.apache.qpid.framing.AMQShortString routingKey,
                         org.apache.qpid.framing.AMQShortString queueName)

AMQDestination

protected AMQDestination(org.apache.qpid.framing.AMQShortString exchangeName,
                         org.apache.qpid.framing.AMQShortString exchangeClass,
                         org.apache.qpid.framing.AMQShortString routingKey,
                         org.apache.qpid.framing.AMQShortString queueName,
                         org.apache.qpid.framing.AMQShortString[] bindingKeys)

AMQDestination

protected AMQDestination(org.apache.qpid.framing.AMQShortString exchangeName,
                         org.apache.qpid.framing.AMQShortString exchangeClass,
                         org.apache.qpid.framing.AMQShortString destinationName)

AMQDestination

protected AMQDestination(org.apache.qpid.framing.AMQShortString exchangeName,
                         org.apache.qpid.framing.AMQShortString exchangeClass,
                         org.apache.qpid.framing.AMQShortString routingKey,
                         boolean isExclusive,
                         boolean isAutoDelete,
                         org.apache.qpid.framing.AMQShortString queueName)

AMQDestination

protected AMQDestination(org.apache.qpid.framing.AMQShortString exchangeName,
                         org.apache.qpid.framing.AMQShortString exchangeClass,
                         org.apache.qpid.framing.AMQShortString routingKey,
                         boolean isExclusive,
                         boolean isAutoDelete,
                         org.apache.qpid.framing.AMQShortString queueName,
                         org.apache.qpid.framing.AMQShortString[] bindingKeys)

AMQDestination

protected AMQDestination(org.apache.qpid.framing.AMQShortString exchangeName,
                         org.apache.qpid.framing.AMQShortString exchangeClass,
                         org.apache.qpid.framing.AMQShortString routingKey,
                         boolean isExclusive,
                         boolean isAutoDelete,
                         org.apache.qpid.framing.AMQShortString queueName,
                         boolean isDurable)

AMQDestination

protected AMQDestination(org.apache.qpid.framing.AMQShortString exchangeName,
                         org.apache.qpid.framing.AMQShortString exchangeClass,
                         org.apache.qpid.framing.AMQShortString routingKey,
                         boolean isExclusive,
                         boolean isAutoDelete,
                         org.apache.qpid.framing.AMQShortString queueName,
                         boolean isDurable,
                         org.apache.qpid.framing.AMQShortString[] bindingKeys)

AMQDestination

protected AMQDestination(org.apache.qpid.framing.AMQShortString exchangeName,
                         org.apache.qpid.framing.AMQShortString exchangeClass,
                         org.apache.qpid.framing.AMQShortString routingKey,
                         boolean isExclusive,
                         boolean isAutoDelete,
                         org.apache.qpid.framing.AMQShortString queueName,
                         boolean isDurable,
                         org.apache.qpid.framing.AMQShortString[] bindingKeys,
                         boolean browseOnly)
Method Detail

getDefaultDestSyntax

public static AMQDestination.DestSyntax getDefaultDestSyntax()

getDestType

public static AMQDestination.DestSyntax getDestType(String str)

stripSyntaxPrefix

public static String stripSyntaxPrefix(String str)

getInfoFromBindingURL

protected void getInfoFromBindingURL(org.apache.qpid.url.BindingURL binding)

getDestSyntax

public AMQDestination.DestSyntax getDestSyntax()

setDestSyntax

protected void setDestSyntax(AMQDestination.DestSyntax syntax)

getEncodedName

public org.apache.qpid.framing.AMQShortString getEncodedName()

isDurable

public boolean isDurable()

getExchangeName

public org.apache.qpid.framing.AMQShortString getExchangeName()

getExchangeClass

public org.apache.qpid.framing.AMQShortString getExchangeClass()

isTopic

public boolean isTopic()

isQueue

public boolean isQueue()

getQueueName

public String getQueueName()

getAMQQueueName

public org.apache.qpid.framing.AMQShortString getAMQQueueName()

setQueueName

public void setQueueName(org.apache.qpid.framing.AMQShortString queueName)

getRoutingKey

public org.apache.qpid.framing.AMQShortString getRoutingKey()

getBindingKeys

public org.apache.qpid.framing.AMQShortString[] getBindingKeys()

isExclusive

public boolean isExclusive()

isAutoDelete

public boolean isAutoDelete()

isNameRequired

public abstract boolean isNameRequired()

toString

public String toString()
Overrides:
toString in class Object

isCheckedForQueueBinding

public boolean isCheckedForQueueBinding()

setCheckedForQueueBinding

public void setCheckedForQueueBinding(boolean checkedForQueueBinding)

isExchangeExistsChecked

public boolean isExchangeExistsChecked()

setExchangeExistsChecked

public void setExchangeExistsChecked(boolean exchangeExistsChecked)

toURL

public String toURL()

toByteEncoding

public byte[] toByteEncoding()

equals

public boolean equals(Object o)
Overrides:
equals in class Object

hashCode

public int hashCode()
Overrides:
hashCode in class Object

getReference

public Reference getReference()
                       throws NamingException
Specified by:
getReference in interface Referenceable
Throws:
NamingException

createDestination

public static Destination createDestination(byte[] byteEncodedDestination)

createDestination

public static Destination createDestination(org.apache.qpid.url.BindingURL binding)

createDestination

public static Destination createDestination(String str)
                                     throws Exception
Throws:
Exception

getAddress

public org.apache.qpid.messaging.Address getAddress()

setAddress

protected void setAddress(org.apache.qpid.messaging.Address addr)

getAddressType

public int getAddressType()

setAddressType

public void setAddressType(int addressType)

getAddressName

public String getAddressName()

setAddressName

public void setAddressName(String name)

getSubject

public String getSubject()

setSubject

public void setSubject(String subject)

getCreate

public AMQDestination.AddressOption getCreate()

setCreate

public void setCreate(AMQDestination.AddressOption option)

getAssert

public AMQDestination.AddressOption getAssert()

setAssert

public void setAssert(AMQDestination.AddressOption option)

getDelete

public AMQDestination.AddressOption getDelete()

setDelete

public void setDelete(AMQDestination.AddressOption option)

getTargetNode

public Node getTargetNode()

setTargetNode

public void setTargetNode(Node node)

getSourceNode

public Node getSourceNode()

setSourceNode

public void setSourceNode(Node node)

getLink

public Link getLink()

setLink

public void setLink(Link link)

setExchangeName

public void setExchangeName(org.apache.qpid.framing.AMQShortString name)

setExchangeClass

public void setExchangeClass(org.apache.qpid.framing.AMQShortString type)

setRoutingKey

public void setRoutingKey(org.apache.qpid.framing.AMQShortString rk)

isAddressResolved

public boolean isAddressResolved()

setAddressResolved

public void setAddressResolved(boolean addressResolved)

rebuildTargetAndSourceNodes

public void rebuildTargetAndSourceNodes(int addressType)

isBrowseOnly

public boolean isBrowseOnly()

setBrowseOnly

public void setBrowseOnly(boolean b)

copyDestination

public AMQDestination copyDestination()

setAutoDelete

protected void setAutoDelete(boolean b)

setDurable

protected void setDurable(boolean b)


Licensed to the Apache Software Foundation