public class AMQQueue extends AMQDestination implements javax.jms.Queue
AMQDestination.AddressOption, AMQDestination.Binding, AMQDestination.DestSyntax
JNDI_ADDRESS_DESTINATION_ADDRESS, QUEUE_TYPE, TOPIC_TYPE, UNKNOWN_TYPE
Constructor and Description |
---|
AMQQueue() |
AMQQueue(Address address) |
AMQQueue(AMQConnection connection,
String name) |
AMQQueue(AMQConnection connection,
String name,
boolean temporary) |
AMQQueue(BindingURL binding)
Create a reference to a non temporary queue using a BindingURL object.
|
AMQQueue(String address) |
AMQQueue(String exchangeName,
String name)
Create a reference to a non temporary queue.
|
AMQQueue(String exchangeName,
String name,
boolean temporary)
Create a queue with a specified name.
|
AMQQueue(String exchangeName,
String routingKey,
String queueName) |
AMQQueue(String exchangeName,
String routingKey,
String queueName,
boolean exclusive,
boolean autoDelete)
Create a reference to a queue.
|
AMQQueue(String exchangeName,
String routingKey,
String queueName,
boolean exclusive,
boolean autoDelete,
boolean durable) |
AMQQueue(String exchangeName,
String routingKey,
String queueName,
boolean exclusive,
boolean autoDelete,
boolean durable,
String[] bindingKeys) |
AMQQueue(String exchangeName,
String routingKey,
String queueName,
String[] bindingKeys) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
String |
getRoutingKey() |
boolean |
isNameRequired() |
copyDestination, createDestination, createDestination, getAddress, getAddressName, getAddressType, getAMQQueueName, getAssert, getBindingKeys, getConsumerArguments, getCreate, getDefaultDestSyntax, getDelete, getDeliveryDelay, getDestinationString, getDestSyntax, getDestType, getEncodedName, getEncryptedRecipients, getExchangeClass, getExchangeName, getInfoFromBindingURL, getLink, getName, getNode, getQueueName, getReference, getRejectBehaviour, getSubject, hashCode, 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 AMQQueue()
public AMQQueue(Address address)
public AMQQueue(String address) throws URISyntaxException
URISyntaxException
public AMQQueue(BindingURL binding)
binding
- a BindingURL objectpublic AMQQueue(String exchangeName, String name)
name
- the name of the queuepublic AMQQueue(String exchangeName, String routingKey, String queueName, String[] bindingKeys)
public AMQQueue(AMQConnection connection, String name)
public AMQQueue(AMQConnection connection, String name, boolean temporary)
public AMQQueue(String exchangeName, String name, boolean temporary)
name
- the destination name (used in the routing key)temporary
- if true the broker will generate a queue name, also if true then the queue is autodeleted
and exclusivepublic AMQQueue(String exchangeName, String routingKey, String queueName, boolean exclusive, boolean autoDelete)
exchangeName
- the exchange name we want to send the message toroutingKey
- the routing keyqueueName
- the queue nameexclusive
- true if the queue should only permit a single consumerautoDelete
- true if the queue should be deleted automatically when the last consumers detachespublic AMQQueue(String exchangeName, String routingKey, String queueName, boolean exclusive, boolean autoDelete, boolean durable)
public String getRoutingKey()
getRoutingKey
in class AMQDestination
public boolean isNameRequired()
isNameRequired
in class AMQDestination
public boolean equals(Object o)
equals
in class AMQDestination
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.