org.apache.qpid.server.exchange

Interface ExchangeImpl<T extends ExchangeImpl<T>>

All Superinterfaces:

ConfiguredObject<T>, Exchange<T>, ExchangeReferrer, MessageDestination, MessageNode

All Known Implementing Classes:

AbstractExchange, DirectExchange, FanoutExchange, HeadersExchange, TopicExchange

public interface ExchangeImpl<T extends ExchangeImpl<T>>
extends Exchange<T>, ExchangeReferrer, MessageDestination

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	ExchangeImpl.BindingListener

Field Summary

Fields inherited from interface org.apache.qpid.server.model.Exchange

ALTERNATE_EXCHANGE, CLASS_DESCRIPTION

Fields inherited from interface org.apache.qpid.server.model.ConfiguredObject

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

Method Summary

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)

Methods inherited from interface org.apache.qpid.server.model.Exchange

createBinding, getAlternateExchange, getBindingCount, getBindings, getBytesDropped, getBytesIn, getMessagesDropped, getMessagesIn, getPublishers

Methods inherited from interface org.apache.qpid.server.model.ConfiguredObject

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

Methods inherited from interface org.apache.qpid.server.message.MessageDestination

getName, send

Method Detail

isAutoDelete

boolean isAutoDelete()

Returns:

true if the exchange will be deleted after all queues have been detached

addBinding

boolean addBinding(String bindingKey,
                   AMQQueue queue,
                   Map<String,Object> arguments)

deleteBinding

boolean deleteBinding(String bindingKey,
                      AMQQueue queue)

hasBinding

boolean hasBinding(String bindingKey,
                   AMQQueue queue)

replaceBinding

boolean replaceBinding(String bindingKey,
                       AMQQueue queue,
                       Map<String,Object> arguments)

isBound

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

Parameters:

bindingKey -

arguments -

queue -

Returns:

isBound

boolean isBound(String bindingKey,
                AMQQueue queue)

Determines whether a message would be isBound to a particular queue using a specific routing key

Parameters:

bindingKey -

queue -

Returns:

isBound

boolean isBound(String bindingKey)

Determines whether a message is routing to any queue using a specific _routing key

Parameters:

bindingKey -

Returns:

hasBindings

boolean hasBindings()

Returns true if this exchange has at least one binding associated with it.

Returns:

isBound

boolean isBound(AMQQueue queue)

isBound

boolean isBound(Map<String,Object> arguments)

isBound

boolean isBound(String bindingKey,
                Map<String,Object> arguments)

isBound

boolean isBound(Map<String,Object> arguments,
                AMQQueue queue)

removeReference

void removeReference(ExchangeReferrer exchange)

addReference

void addReference(ExchangeReferrer exchange)

hasReferrers

boolean hasReferrers()

removeBindingAsync

com.google.common.util.concurrent.ListenableFuture<Void> removeBindingAsync(BindingImpl binding)

getBinding

BindingImpl getBinding(String bindingName,
                       AMQQueue queue)

getEventLogger

EventLogger getEventLogger()

addBinding

void addBinding(BindingImpl binding)