Modifier and Type | Method and Description |
---|---|
AMQQueue |
BindingImpl.getAMQQueue() |
Constructor and Description |
---|
BindingImpl(Map<String,Object> attributes,
AMQQueue queue,
ExchangeImpl exchange) |
Modifier and Type | Method and Description |
---|---|
boolean |
ExchangeImpl.addBinding(String bindingKey,
AMQQueue queue,
Map<String,Object> arguments) |
boolean |
AbstractExchange.addBinding(String bindingKey,
AMQQueue queue,
Map<String,Object> arguments) |
boolean |
ExchangeImpl.deleteBinding(String bindingKey,
AMQQueue queue) |
boolean |
AbstractExchange.deleteBinding(String bindingKey,
AMQQueue queue) |
BindingImpl |
ExchangeImpl.getBinding(String bindingName,
AMQQueue queue) |
BindingImpl |
AbstractExchange.getBinding(String bindingKey,
AMQQueue queue) |
boolean |
ExchangeImpl.hasBinding(String bindingKey,
AMQQueue queue) |
boolean |
AbstractExchange.hasBinding(String bindingKey,
AMQQueue queue) |
boolean |
ExchangeImpl.isBound(AMQQueue queue) |
boolean |
AbstractExchange.isBound(AMQQueue queue) |
boolean |
ExchangeImpl.isBound(Map<String,Object> arguments,
AMQQueue queue) |
boolean |
AbstractExchange.isBound(Map<String,Object> arguments,
AMQQueue queue) |
boolean |
ExchangeImpl.isBound(String bindingKey,
AMQQueue queue)
Determines whether a message would be isBound to a particular queue using a specific routing key
|
boolean |
AbstractExchange.isBound(String bindingKey,
AMQQueue queue) |
boolean |
ExchangeImpl.isBound(String bindingKey,
Map<String,Object> arguments,
AMQQueue queue)
Determines whether a message would be isBound to a particular queue using a specific routing key and arguments
|
boolean |
AbstractExchange.isBound(String bindingKey,
Map<String,Object> arguments,
AMQQueue queue) |
boolean |
ExchangeImpl.replaceBinding(String bindingKey,
AMQQueue queue,
Map<String,Object> arguments) |
boolean |
AbstractExchange.replaceBinding(String bindingKey,
AMQQueue queue,
Map<String,Object> arguments) |
Modifier and Type | Method and Description |
---|---|
Collection<AMQQueue> |
TopicExchangeResult.getUnfilteredQueues() |
Collection<AMQQueue> |
TopicExchangeResult.processMessage(Filterable msg,
Collection<AMQQueue> queues) |
Modifier and Type | Method and Description |
---|---|
void |
TopicExchangeResult.addFilteredQueue(AMQQueue queue,
FilterManager filter) |
void |
TopicExchangeResult.addUnfilteredQueue(AMQQueue queue) |
void |
TopicExchangeResult.removeFilteredQueue(AMQQueue queue,
FilterManager filter) |
void |
TopicExchangeResult.removeUnfilteredQueue(AMQQueue queue) |
void |
TopicExchangeResult.replaceQueueFilter(AMQQueue queue,
FilterManager oldFilter,
FilterManager newFilter) |
Modifier and Type | Method and Description |
---|---|
Collection<AMQQueue> |
TopicExchangeResult.processMessage(Filterable msg,
Collection<AMQQueue> queues) |
Modifier and Type | Method and Description |
---|---|
static FilterManager |
FilterSupport.createMessageFilter(Map<String,Object> args,
AMQQueue queue) |
Constructor and Description |
---|
BindingLogSubject(String routingKey,
ExchangeImpl exchange,
AMQQueue queue)
Create a BindingLogSubject that Logs in the following format.
|
QueueLogSubject(AMQQueue queue)
Create an QueueLogSubject that Logs in the following format.
|
Modifier and Type | Method and Description |
---|---|
void |
AMQSessionModel.block(AMQQueue queue) |
void |
AMQSessionModel.unblock(AMQQueue queue) |
Modifier and Type | Method and Description |
---|---|
void |
ServerSession.block(AMQQueue queue) |
void |
ServerSession.unblock(AMQQueue queue) |
Modifier and Type | Method and Description |
---|---|
void |
AMQChannel.block(AMQQueue queue) |
void |
AMQChannel.unblock(AMQQueue queue) |
Modifier and Type | Method and Description |
---|---|
AMQQueue |
QueueDestination.getQueue() |
Modifier and Type | Method and Description |
---|---|
void |
Session_1_0.block(AMQQueue queue) |
void |
Session_1_0.unblock(AMQQueue queue) |
Constructor and Description |
---|
QueueDestination(AMQQueue queue) |
Modifier and Type | Interface and Description |
---|---|
interface |
AMQQueue<X extends AMQQueue<X>> |
Modifier and Type | Interface and Description |
---|---|
interface |
LastValueQueue<X extends LastValueQueue<X>> |
interface |
PriorityQueue<X extends PriorityQueue<X>> |
interface |
SortedQueue<X extends SortedQueue<X>> |
interface |
StandardQueue<X extends StandardQueue<X>> |
Modifier and Type | Class and Description |
---|---|
class |
AbstractQueue<X extends AbstractQueue<X>> |
class |
LastValueQueueImpl |
class |
OutOfOrderQueue<X extends OutOfOrderQueue<X>> |
class |
PriorityQueueImpl |
class |
SortedQueueImpl |
class |
StandardQueueImpl |
Modifier and Type | Method and Description |
---|---|
AMQQueue<?> |
QueueEntryList.getQueue() |
AMQQueue |
OrderedQueueEntryList.getQueue() |
AMQQueue |
QueueEntryImpl.getQueue() |
AMQQueue |
QueueConsumer.getQueue() |
AMQQueue |
QueueEntry.getQueue() |
Modifier and Type | Method and Description |
---|---|
int |
AbstractQueue.compareTo(AMQQueue o) |
abstract boolean |
NotificationCheck.notifyIfNecessary(ServerMessage<?> msg,
AMQQueue queue,
QueueNotificationListener listener) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractQueue.addDeleteTask(Action<? super AMQQueue> task) |
void |
AbstractQueue.removeDeleteTask(Action<? super AMQQueue> task) |
Constructor and Description |
---|
OrderedQueueEntryList(AMQQueue queue,
OrderedQueueEntryList.HeadCreator headCreator) |
Modifier and Type | Interface and Description |
---|---|
interface |
VirtualHostImpl<X extends VirtualHostImpl<X,Q,E>,Q extends AMQQueue<?>,E extends ExchangeImpl<?>> |
Modifier and Type | Method and Description |
---|---|
AMQQueue<?> |
AbstractVirtualHost.createQueue(Map<String,Object> attributes) |
AMQQueue<?> |
AbstractVirtualHost.getAttainedQueue(String name) |
AMQQueue<?> |
AbstractVirtualHost.getAttainedQueue(UUID id) |
AMQQueue |
QueueExistsException.getExistingQueue() |
Modifier and Type | Method and Description |
---|---|
Collection<AMQQueue<?>> |
AbstractVirtualHost.getQueues() |
Modifier and Type | Method and Description |
---|---|
int |
AbstractVirtualHost.removeQueue(AMQQueue<?> queue) |
com.google.common.util.concurrent.ListenableFuture<Integer> |
AbstractVirtualHost.removeQueueAsync(AMQQueue<?> queue) |
Constructor and Description |
---|
QueueExistsException(AMQQueue existing) |
QueueExistsException(String name,
AMQQueue existing) |
Modifier and Type | Method and Description |
---|---|
AMQQueue<?> |
BDBHAReplicaVirtualHostImpl.createQueue(Map<String,Object> attributes) |
AMQQueue<?> |
BDBHAReplicaVirtualHostImpl.getAttainedQueue(String name) |
AMQQueue<?> |
BDBHAReplicaVirtualHostImpl.getAttainedQueue(UUID id) |
Modifier and Type | Method and Description |
---|---|
Collection<AMQQueue<?>> |
BDBHAReplicaVirtualHostImpl.getQueues() |
Modifier and Type | Method and Description |
---|---|
int |
BDBHAReplicaVirtualHostImpl.removeQueue(AMQQueue<?> queue) |
com.google.common.util.concurrent.ListenableFuture<Integer> |
BDBHAReplicaVirtualHostImpl.removeQueueAsync(AMQQueue<?> queue) |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.