public class AMQTopic extends AMQDestination implements javax.jms.Topic
AMQDestination.AddressOption, AMQDestination.Binding, AMQDestination.DestSyntax
JNDI_ADDRESS_DESTINATION_ADDRESS, QUEUE_TYPE, TOPIC_TYPE, UNKNOWN_TYPE
Modifier | Constructor and Description |
---|---|
|
AMQTopic() |
|
AMQTopic(Address address) |
|
AMQTopic(AMQConnection conn,
String routingKey) |
|
AMQTopic(BindingURL binding)
Constructor for use in creating a topic using a BindingURL.
|
|
AMQTopic(String address) |
|
AMQTopic(String exchangeName,
String routingKey) |
|
AMQTopic(String exchangeName,
String name,
boolean isAutoDelete,
String queueName,
boolean isDurable) |
|
AMQTopic(String exchange,
String routingKey,
String queueName) |
protected |
AMQTopic(String exchangeName,
String exchangeClass,
String routingKey,
boolean isExclusive,
boolean isAutoDelete,
String queueName,
boolean isDurable) |
protected |
AMQTopic(String exchangeName,
String exchangeClass,
String routingKey,
boolean isExclusive,
boolean isAutoDelete,
String queueName,
boolean isDurable,
String[] bindingKeys) |
protected |
AMQTopic(String exchangeName,
String exchangeClass,
String name,
boolean isAutoDelete,
String queueName,
boolean isDurable) |
|
AMQTopic(String exchange,
String routingKey,
String queueName,
String[] bindingKeys) |
Modifier and Type | Method and Description |
---|---|
static AMQTopic |
createDurableTopic(javax.jms.Topic topic,
String subscriptionName,
AMQConnection connection) |
boolean |
equals(Object o) |
static String |
getDurableTopicQueueName(String subscriptionName,
AMQConnection connection) |
String |
getExchangeName() |
String |
getRoutingKey() |
String |
getTopicName() |
int |
hashCode() |
boolean |
isNameRequired() |
copyDestination, createDestination, createDestination, getAddress, getAddressName, getAddressType, getAMQQueueName, getAssert, getBindingKeys, getConsumerArguments, getCreate, getDefaultDestSyntax, getDelete, getDeliveryDelay, getDestinationString, getDestSyntax, getDestType, getEncodedName, getEncryptedRecipients, getExchangeClass, getInfoFromBindingURL, getLink, getName, getNode, getQueueName, getReference, getRejectBehaviour, getSubject, isAutoDelete, isBrowseOnly, isCheckedForQueueBinding, isDefaultExchange, isDurable, isExchangeAutoDelete, isExchangeDurable, isExchangeInternal, isExclusive, isQueue, isTopic, neverDeclare, parseDestinationString, readExternal, sendEncrypted, setAddress, setAddressName, setAddressType, setAssert, setAutoDelete, setCheckedForQueueBinding, setCreate, setDelete, setDestinationString, setDestSyntax, setDurable, setExchangeClass, setExchangeName, setExclusive, setLink, setName, setNode, setQueueName, setRoutingKey, setSubject, stripSyntaxPrefix, toString, toURL, writeExternal
public AMQTopic(String address) throws URISyntaxException
URISyntaxException
public AMQTopic(Address address)
public AMQTopic()
public AMQTopic(BindingURL binding)
binding
- The binding url object.public AMQTopic(String exchange, String routingKey, String queueName, String[] bindingKeys)
public AMQTopic(AMQConnection conn, String routingKey)
public AMQTopic(String exchangeName, String name, boolean isAutoDelete, String queueName, boolean isDurable)
protected AMQTopic(String exchangeName, String exchangeClass, String name, boolean isAutoDelete, String queueName, boolean isDurable)
protected AMQTopic(String exchangeName, String exchangeClass, String routingKey, boolean isExclusive, boolean isAutoDelete, String queueName, boolean isDurable)
public static AMQTopic createDurableTopic(javax.jms.Topic topic, String subscriptionName, AMQConnection connection) throws javax.jms.JMSException
javax.jms.JMSException
public static String getDurableTopicQueueName(String subscriptionName, AMQConnection connection) throws javax.jms.JMSException
javax.jms.JMSException
public String getTopicName() throws javax.jms.JMSException
getTopicName
in interface javax.jms.Topic
javax.jms.JMSException
public String getExchangeName()
getExchangeName
in class AMQDestination
public String getRoutingKey()
getRoutingKey
in class AMQDestination
public boolean isNameRequired()
isNameRequired
in class AMQDestination
public boolean equals(Object o)
equals
in class AMQDestination
public int hashCode()
hashCode
in class AMQDestination
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.