org.apache.qpid.client
Class AMQDestination
java.lang.Object
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
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)
|
_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
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)
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