Modifier and Type | Method and Description |
---|---|
ExchangeImpl<?> |
BindingImpl.getExchange() |
Constructor and Description |
---|
BindingImpl(Map<String,Object> attributes,
AMQQueue queue,
ExchangeImpl exchange) |
Modifier and Type | Interface and Description |
---|---|
interface |
ExchangeImpl<T extends ExchangeImpl<T>> |
Modifier and Type | Class and Description |
---|---|
class |
AbstractExchange<T extends AbstractExchange<T>> |
class |
DirectExchange |
class |
FanoutExchange |
class |
HeadersExchange
An exchange that binds queues based on a set of required headers and header values
and routes messages to these queues by matching the headers of the message against
those with which the queues were bound.
|
class |
TopicExchange |
Modifier and Type | Method and Description |
---|---|
void |
ExchangeImpl.BindingListener.bindingAdded(ExchangeImpl exchange,
BindingImpl binding) |
void |
ExchangeImpl.BindingListener.bindingRemoved(ExchangeImpl exchange,
BindingImpl binding) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractExchange.addCloseTask(Action<ExchangeImpl> task) |
void |
AbstractExchange.removeCloseTask(Action<ExchangeImpl> task) |
Constructor and Description |
---|
BindingLogSubject(String routingKey,
ExchangeImpl exchange,
AMQQueue queue)
Create a BindingLogSubject that Logs in the following format.
|
ExchangeLogSubject(ExchangeImpl exchange,
VirtualHostImpl vhost)
Create an ExchangeLogSubject that Logs in the following format.
|
Modifier and Type | Method and Description |
---|---|
ExchangeImpl |
ExchangeDestination.getExchange() |
Constructor and Description |
---|
ExchangeDestination(ExchangeImpl exchange,
TerminusDurability durable,
TerminusExpiryPolicy expiryPolicy) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractQueue.setAlternateExchange(ExchangeImpl exchange) |
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 |
---|---|
ExchangeImpl |
AbstractVirtualHost.createExchange(Map<String,Object> attributes) |
ExchangeImpl |
AbstractVirtualHost.getAttainedExchange(String name) |
ExchangeImpl |
ExchangeExistsException.getExistingExchange() |
Modifier and Type | Method and Description |
---|---|
Collection<ExchangeImpl<?>> |
AbstractVirtualHost.getExchanges() |
Constructor and Description |
---|
ExchangeExistsException(ExchangeImpl existing) |
ExchangeExistsException(String message,
ExchangeImpl existing) |
Modifier and Type | Method and Description |
---|---|
ExchangeImpl |
BDBHAReplicaVirtualHostImpl.createExchange(Map<String,Object> attributes) |
ExchangeImpl<?> |
BDBHAReplicaVirtualHostImpl.getAttainedExchange(String name) |
Modifier and Type | Method and Description |
---|---|
Collection<ExchangeImpl<?>> |
BDBHAReplicaVirtualHostImpl.getExchanges() |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.