public interface ExchangeImpl<T extends ExchangeImpl<T>> extends Exchange<T>, ExchangeReferrer, MessageDestination
Modifier and Type | Interface and Description |
---|---|
static interface |
ExchangeImpl.BindingListener |
ALTERNATE_EXCHANGE, CLASS_DESCRIPTION
CONTEXT, CREATED_BY, CREATED_TIME, DESCRIPTION, DESIRED_STATE, DURABLE, ID, LAST_UPDATED_BY, LAST_UPDATED_TIME, LIFETIME_POLICY, NAME, OVER_SIZED_ATTRIBUTE_ALTERNATIVE_TEXT, STATE, TYPE
Modifier and Type | Method and Description |
---|---|
void |
addBinding(BindingImpl binding) |
boolean |
addBinding(String bindingKey,
AMQQueue queue,
Map<String,Object> arguments) |
void |
addReference(ExchangeReferrer exchange) |
boolean |
deleteBinding(String bindingKey,
AMQQueue queue) |
BindingImpl |
getBinding(String bindingName,
AMQQueue queue) |
EventLogger |
getEventLogger() |
boolean |
hasBinding(String bindingKey,
AMQQueue queue) |
boolean |
hasBindings()
Returns true if this exchange has at least one binding associated with it.
|
boolean |
hasReferrers() |
boolean |
isAutoDelete() |
boolean |
isBound(AMQQueue queue) |
boolean |
isBound(Map<String,Object> arguments) |
boolean |
isBound(Map<String,Object> arguments,
AMQQueue queue) |
boolean |
isBound(String bindingKey)
Determines whether a message is routing to any queue using a specific _routing key
|
boolean |
isBound(String bindingKey,
AMQQueue queue)
Determines whether a message would be isBound to a particular queue using a specific routing key
|
boolean |
isBound(String bindingKey,
Map<String,Object> arguments) |
boolean |
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
|
com.google.common.util.concurrent.ListenableFuture<Void> |
removeBindingAsync(BindingImpl binding) |
void |
removeReference(ExchangeReferrer exchange) |
boolean |
replaceBinding(String bindingKey,
AMQQueue queue,
Map<String,Object> arguments) |
createBinding, getAlternateExchange, getBindingCount, getBindings, getBytesDropped, getBytesIn, getMessagesDropped, getMessagesIn, getPublishers
addChangeListener, asObjectRecord, close, closeAsync, createChild, createChildAsync, decryptSecrets, delete, deleteAsync, findConfiguredObject, getActualAttributes, getAttainedChildById, getAttainedChildByName, getAttribute, getAttributeNames, getCategoryClass, getChildById, getChildByName, getChildExecutor, getChildren, getContext, getContextKeys, getContextValue, getContextValue, getCreatedBy, getCreatedTime, getDescription, getDesiredState, getId, getLastOpenedTime, getLastUpdatedBy, getLastUpdatedTime, getLifetimePolicy, getModel, getName, getObjectFactory, getParent, getState, getStatistics, getTaskExecutor, getType, getTypeClass, isDurable, managesChildStorage, open, openAsync, removeChangeListener, setAttribute, setAttributes, setAttributesAsync
getName, send
boolean isAutoDelete()
boolean replaceBinding(String bindingKey, AMQQueue queue, Map<String,Object> arguments)
boolean isBound(String bindingKey, Map<String,Object> arguments, AMQQueue queue)
bindingKey
- arguments
- queue
- boolean isBound(String bindingKey, AMQQueue queue)
bindingKey
- queue
- boolean isBound(String bindingKey)
bindingKey
- boolean hasBindings()
boolean isBound(AMQQueue queue)
void removeReference(ExchangeReferrer exchange)
void addReference(ExchangeReferrer exchange)
boolean hasReferrers()
com.google.common.util.concurrent.ListenableFuture<Void> removeBindingAsync(BindingImpl binding)
BindingImpl getBinding(String bindingName, AMQQueue queue)
EventLogger getEventLogger()
void addBinding(BindingImpl binding)
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.