public abstract class AMQDestination extends Object implements javax.jms.Destination, Referenceable, Externalizable
Modifier and Type | Class and Description |
---|---|
static class |
AMQDestination.AddressOption |
static class |
AMQDestination.Binding |
static class |
AMQDestination.DestSyntax |
Modifier and Type | Field and Description |
---|---|
static String |
JNDI_ADDRESS_DESTINATION_ADDRESS |
static int |
QUEUE_TYPE |
static int |
TOPIC_TYPE |
static int |
UNKNOWN_TYPE |
Modifier | Constructor and Description |
---|---|
protected |
AMQDestination() |
protected |
AMQDestination(Address address) |
protected |
AMQDestination(BindingURL binding) |
protected |
AMQDestination(String str) |
protected |
AMQDestination(String exchangeName,
String exchangeClass,
String destinationName) |
protected |
AMQDestination(String exchangeName,
String exchangeClass,
String routingKey,
boolean isExclusive,
boolean isAutoDelete,
String queueName) |
protected |
AMQDestination(String exchangeName,
String exchangeClass,
String routingKey,
boolean isExclusive,
boolean isAutoDelete,
String queueName,
boolean isDurable) |
protected |
AMQDestination(String exchangeName,
String exchangeClass,
String routingKey,
boolean isExclusive,
boolean isAutoDelete,
String queueName,
boolean isDurable,
String[] bindingKeys) |
protected |
AMQDestination(String exchangeName,
String exchangeClass,
String routingKey,
boolean isExclusive,
boolean isAutoDelete,
String queueName,
boolean isDurable,
String[] bindingKeys,
boolean browseOnly) |
protected |
AMQDestination(String exchangeName,
String exchangeClass,
String routingKey,
boolean isExclusive,
boolean isAutoDelete,
String queueName,
String[] bindingKeys) |
protected |
AMQDestination(String exchangeName,
String exchangeClass,
String routingKey,
String queueName) |
protected |
AMQDestination(String exchangeName,
String exchangeClass,
String routingKey,
String queueName,
String[] bindingKeys) |
public static final String JNDI_ADDRESS_DESTINATION_ADDRESS
public static final int QUEUE_TYPE
public static final int TOPIC_TYPE
public static final int UNKNOWN_TYPE
protected AMQDestination()
protected AMQDestination(Address address)
protected AMQDestination(String str) throws URISyntaxException
URISyntaxException
protected AMQDestination(BindingURL binding)
protected AMQDestination(String exchangeName, String exchangeClass, String routingKey, String queueName)
protected AMQDestination(String exchangeName, String exchangeClass, String routingKey, String queueName, String[] bindingKeys)
protected AMQDestination(String exchangeName, String exchangeClass, String destinationName)
protected AMQDestination(String exchangeName, String exchangeClass, String routingKey, boolean isExclusive, boolean isAutoDelete, String queueName)
protected AMQDestination(String exchangeName, String exchangeClass, String routingKey, boolean isExclusive, boolean isAutoDelete, String queueName, String[] bindingKeys)
protected AMQDestination(String exchangeName, String exchangeClass, String routingKey, boolean isExclusive, boolean isAutoDelete, String queueName, boolean isDurable)
protected AMQDestination(String exchangeName, String exchangeClass, String routingKey, boolean isExclusive, boolean isAutoDelete, String queueName, boolean isDurable, String[] bindingKeys)
protected void setExclusive(boolean exclusive)
protected String getName()
protected void setName(String name)
public boolean neverDeclare()
public boolean sendEncrypted()
public String getEncryptedRecipients()
public long getDeliveryDelay()
public static AMQDestination.DestSyntax getDefaultDestSyntax()
public static AMQDestination.DestSyntax getDestType(String str)
protected void parseDestinationString(String str) throws URISyntaxException
URISyntaxException
protected void getInfoFromBindingURL(BindingURL binding)
public void setDestinationString(String str) throws Exception
Exception
public String getDestinationString()
public AMQDestination.DestSyntax getDestSyntax()
protected void setDestSyntax(AMQDestination.DestSyntax syntax)
public AMQShortString getEncodedName()
public boolean isDurable()
public String getExchangeName()
public boolean isDefaultExchange()
public String getExchangeClass()
public boolean isExchangeDurable()
public boolean isExchangeAutoDelete()
public boolean isExchangeInternal()
public boolean isTopic()
public boolean isQueue()
public String getQueueName()
public String getAMQQueueName()
public void setQueueName(String queueName)
public String getRoutingKey()
public String[] getBindingKeys()
public boolean isExclusive()
public boolean isAutoDelete()
public abstract boolean isNameRequired()
public boolean isCheckedForQueueBinding()
public void setCheckedForQueueBinding(boolean checkedForQueueBinding)
public String toURL()
public Reference getReference() throws NamingException
getReference
in interface Referenceable
NamingException
public static javax.jms.Destination createDestination(BindingURL binding)
public static javax.jms.Destination createDestination(String str, boolean useNodeTypeForDestinationType) throws URISyntaxException
URISyntaxException
public Address getAddress()
protected void setAddress(Address addr)
public int getAddressType()
public void setAddressType(int addressType)
public String getAddressName()
public void setAddressName(String name)
public String getSubject()
public void setSubject(String subject)
public AMQDestination.AddressOption getCreate()
public void setCreate(AMQDestination.AddressOption option)
public AMQDestination.AddressOption getAssert()
public void setAssert(AMQDestination.AddressOption option)
public AMQDestination.AddressOption getDelete()
public void setDelete(AMQDestination.AddressOption option)
public Node getNode()
public void setNode(Node node)
public Link getLink()
public void setLink(Link link)
public void setExchangeName(String name)
public void setExchangeClass(String type)
public void setRoutingKey(String rk)
public boolean isBrowseOnly()
public AMQDestination copyDestination()
protected void setAutoDelete(boolean b)
protected void setDurable(boolean b)
public RejectBehaviour getRejectBehaviour()
It tells the client to delegate the requeue/DLQ decision to the server .If this option is not specified, the messages won't be moved to the DLQ (or dropped) when delivery count exceeds the maximum.
public void writeExternal(ObjectOutput out) throws IOException
writeExternal
in interface Externalizable
IOException
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal
in interface Externalizable
IOException
ClassNotFoundException
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.