org.apache.qpid.server.exchange

Class AbstractExchange<T extends AbstractExchange<T>>

java.lang.Object

org.apache.qpid.server.model.AbstractConfiguredObject<T>

org.apache.qpid.server.exchange.AbstractExchange<T>

All Implemented Interfaces:

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

Direct Known Subclasses:

DirectExchange, FanoutExchange, HeadersExchange, TopicExchange

public abstract class AbstractExchange<T extends AbstractExchange<T>>
extends AbstractConfiguredObject<T>
implements ExchangeImpl<T>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.qpid.server.model.AbstractConfiguredObject

AbstractConfiguredObject.CallableWithArgument<V,A>, AbstractConfiguredObject.ChainedListenableFuture<V>, AbstractConfiguredObject.ChainedSettableFuture<V>, AbstractConfiguredObject.DuplicateIdException, AbstractConfiguredObject.DuplicateNameException

Nested classes/interfaces inherited from interface org.apache.qpid.server.exchange.ExchangeImpl

ExchangeImpl.BindingListener

Field Summary

Fields inherited from class org.apache.qpid.server.model.AbstractConfiguredObject

SECURED_STRING_VALUE

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

Constructor Summary

Constructors

Constructor and Description
AbstractExchange(Map<String,Object> attributes, VirtualHostImpl vhost)

Method Summary

Modifier and Type	Method and Description
void	addBinding(BindingImpl b)
boolean	addBinding(String bindingKey, AMQQueue queue, Map<String,Object> arguments)
void	addBindingListener(ExchangeImpl.BindingListener listener)
void	addCloseTask(Action<ExchangeImpl> task)
void	addReference(ExchangeReferrer exchange)
Binding	createBinding(String bindingKey, Queue queue, Map<String,Object> bindingArguments, Map<String,Object> attributes)
boolean	deleteBinding(String bindingKey, AMQQueue queue)
void	doAddBinding(BindingImpl binding)
void	doRemoveBinding(BindingImpl binding)
protected abstract List<? extends BaseQueue>	doRoute(ServerMessage message, String routingAddress, InstanceProperties instanceProperties)
Exchange<?>	getAlternateExchange()
Map<String,Object>	getArguments()
BindingImpl	getBinding(String bindingKey, AMQQueue queue)
long	getBindingCount()
long	getBindingCountHigh()
Collection<BindingImpl>	getBindings()
long	getByteRoutes()
long	getBytesDropped()
long	getBytesIn()
<C extends ConfiguredObject> Collection<C>	getChildren(Class<C> clazz) Return children of the ConfiguredObject of the given class
EventLogger	getEventLogger()
long	getMessagesDropped()
long	getMessagesIn()
long	getMsgRoutes()
Collection<Publisher>	getPublishers()
VirtualHostImpl	getVirtualHost()
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
protected abstract void	onBind(BindingImpl binding)
protected abstract void	onBindingUpdated(BindingImpl binding, Map<String,Object> oldArguments)
protected void	onOpen()
protected abstract void	onUnbind(BindingImpl binding)
void	onValidate() Validation performed for configured object creation and opening.
com.google.common.util.concurrent.ListenableFuture<Void>	removeBindingAsync(BindingImpl binding)
void	removeBindingListener(ExchangeImpl.BindingListener listener)
void	removeCloseTask(Action<ExchangeImpl> task)
void	removeReference(ExchangeReferrer exchange)
boolean	replaceBinding(String bindingKey, AMQQueue queue, Map<String,Object> arguments)
<M extends ServerMessage<? extends StorableMessageMetaData>> int	send(M message, String routingAddress, InstanceProperties instanceProperties, ServerTransaction txn, Action<? super MessageInstance> postEnqueueAction) Routes a message
String	toString()

Methods inherited from class org.apache.qpid.server.model.AbstractConfiguredObject

addChangeListener, addChildAsync, applyToChildren, asObjectRecord, attainState, attributeSet, authoriseCreate, authoriseCreateChild, authoriseDelete, authoriseSetAttributes, beforeClose, changeAttribute, changeAttributes, childAdded, childRemoved, close, closeAsync, closeChildren, create, createAsync, createChild, createChildAsync, decryptSecrets, delete, deleteAsync, deleted, doAfter, doAfter, doAfter, doAfter, doAfter, doAfter, doAfterAlways, doAfterAlways, doCreation, doOnConfigThread, doOpening, doResolution, doSync, doSync, doValidation, findConfiguredObject, forceUpdateAllSecureAttributes, getActualAttributes, getAttainedChildById, getAttainedChildByName, getAttribute, getAttributeNames, getCategoryClass, getChildById, getChildByName, getChildExecutor, getContext, getContextKeys, getContextValue, getContextValue, getCreatedBy, getCreatedTime, getDescription, getDesiredState, getId, getLastOpenedTime, getLastUpdatedBy, getLastUpdatedTime, getLifetimePolicy, getModel, getName, getObjectFactory, getParent, getSecurityManager, getState, getStatistics, getTaskExecutor, getType, getTypeClass, handleExceptionOnOpen, isDurable, managesChildStorage, notifyStateChanged, onClose, onCreate, onExceptionInOpen, onResolve, open, openAsync, parentsMap, postResolve, postResolveChildren, registerWithParents, removeChangeListener, rethrowRuntimeExceptionsOnOpen, runTask, setAttribute, setAttributes, setAttributesAsync, setEncrypter, setState, start, startAsync, stop, validateChange, validateOnCreate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

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, 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

Constructor Detail

AbstractExchange

public AbstractExchange(Map<String,Object> attributes,
                        VirtualHostImpl vhost)

Method Detail

onValidate

public void onValidate()

Description copied from class: AbstractConfiguredObject

Validation performed for configured object creation and opening.

Overrides:

onValidate in class AbstractConfiguredObject<T extends AbstractExchange<T>>

onOpen

protected void onOpen()

Overrides:

onOpen in class AbstractConfiguredObject<T extends AbstractExchange<T>>

getEventLogger

public EventLogger getEventLogger()

Specified by:

getEventLogger in interface ExchangeImpl<T extends AbstractExchange<T>>

isAutoDelete

public boolean isAutoDelete()

Specified by:

isAutoDelete in interface ExchangeImpl<T extends AbstractExchange<T>>

Returns:

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

toString

public String toString()

Overrides:

toString in class AbstractConfiguredObject<T extends AbstractExchange<T>>

getVirtualHost

public VirtualHostImpl getVirtualHost()

isBound

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

Description copied from interface: ExchangeImpl

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

Specified by:

isBound in interface ExchangeImpl<T extends AbstractExchange<T>>

Returns:

isBound

public final boolean isBound(String bindingKey,
                             AMQQueue queue)

Description copied from interface: ExchangeImpl

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

Specified by:

isBound in interface ExchangeImpl<T extends AbstractExchange<T>>

Returns:

isBound

public final boolean isBound(String bindingKey)

Description copied from interface: ExchangeImpl

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

Specified by:

isBound in interface ExchangeImpl<T extends AbstractExchange<T>>

Returns:

isBound

public final boolean isBound(AMQQueue queue)

Specified by:

isBound in interface ExchangeImpl<T extends AbstractExchange<T>>

isBound

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

Specified by:

isBound in interface ExchangeImpl<T extends AbstractExchange<T>>

isBound

public final boolean isBound(Map<String,Object> arguments)

Specified by:

isBound in interface ExchangeImpl<T extends AbstractExchange<T>>

isBound

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

Specified by:

isBound in interface ExchangeImpl<T extends AbstractExchange<T>>

hasBindings

public final boolean hasBindings()

Description copied from interface: ExchangeImpl

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

Specified by:

hasBindings in interface ExchangeImpl<T extends AbstractExchange<T>>

Returns:

getAlternateExchange

public Exchange<?> getAlternateExchange()

Specified by:

getAlternateExchange in interface Exchange<T extends AbstractExchange<T>>

removeReference

public void removeReference(ExchangeReferrer exchange)

Specified by:

removeReference in interface ExchangeImpl<T extends AbstractExchange<T>>

addReference

public void addReference(ExchangeReferrer exchange)

Specified by:

addReference in interface ExchangeImpl<T extends AbstractExchange<T>>

hasReferrers

public boolean hasReferrers()

Specified by:

hasReferrers in interface ExchangeImpl<T extends AbstractExchange<T>>

addCloseTask

public void addCloseTask(Action<ExchangeImpl> task)

removeCloseTask

public void removeCloseTask(Action<ExchangeImpl> task)

doAddBinding

public final void doAddBinding(BindingImpl binding)

getBindingCountHigh

public long getBindingCountHigh()

doRemoveBinding

public final void doRemoveBinding(BindingImpl binding)

getBindings

public final Collection<BindingImpl> getBindings()

Specified by:

getBindings in interface Exchange<T extends AbstractExchange<T>>

onBind

protected abstract void onBind(BindingImpl binding)

onUnbind

protected abstract void onUnbind(BindingImpl binding)

getArguments

public Map<String,Object> getArguments()

getBindingCount

public long getBindingCount()

Specified by:

getBindingCount in interface Exchange<T extends AbstractExchange<T>>

send

public final <M extends ServerMessage<? extends StorableMessageMetaData>> int send(M message,
                                                                                   String routingAddress,
                                                                                   InstanceProperties instanceProperties,
                                                                                   ServerTransaction txn,
                                                                                   Action<? super MessageInstance> postEnqueueAction)

Description copied from interface: MessageDestination

Routes a message

Specified by:

send in interface MessageDestination

Parameters:

message - the message to be routed

instanceProperties - the instance properties

txn - the transaction to enqueue within

postEnqueueAction - action to perform on the result of every enqueue (may be null)

Returns:

the number of queues in which the message was enqueued performed

doRoute

protected abstract List<? extends BaseQueue> doRoute(ServerMessage message,
                                                     String routingAddress,
                                                     InstanceProperties instanceProperties)

getMessagesIn

public long getMessagesIn()

Specified by:

getMessagesIn in interface Exchange<T extends AbstractExchange<T>>

getMsgRoutes

public long getMsgRoutes()

getMessagesDropped

public long getMessagesDropped()

Specified by:

getMessagesDropped in interface Exchange<T extends AbstractExchange<T>>

getBytesIn

public long getBytesIn()

Specified by:

getBytesIn in interface Exchange<T extends AbstractExchange<T>>

getByteRoutes

public long getByteRoutes()

getBytesDropped

public long getBytesDropped()

Specified by:

getBytesDropped in interface Exchange<T extends AbstractExchange<T>>

addBindingListener

public void addBindingListener(ExchangeImpl.BindingListener listener)

removeBindingListener

public void removeBindingListener(ExchangeImpl.BindingListener listener)

addBinding

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

Specified by:

addBinding in interface ExchangeImpl<T extends AbstractExchange<T>>

replaceBinding

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

Specified by:

replaceBinding in interface ExchangeImpl<T extends AbstractExchange<T>>

removeBindingAsync

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

Specified by:

removeBindingAsync in interface ExchangeImpl<T extends AbstractExchange<T>>

getBinding

public BindingImpl getBinding(String bindingKey,
                              AMQQueue queue)

Specified by:

getBinding in interface ExchangeImpl<T extends AbstractExchange<T>>

addBinding

public void addBinding(BindingImpl b)

Specified by:

addBinding in interface ExchangeImpl<T extends AbstractExchange<T>>

onBindingUpdated

protected abstract void onBindingUpdated(BindingImpl binding,
                                         Map<String,Object> oldArguments)

getChildren

public <C extends ConfiguredObject> Collection<C> getChildren(Class<C> clazz)

Description copied from interface: ConfiguredObject

Return children of the ConfiguredObject of the given class

Specified by:

getChildren in interface ConfiguredObject<T extends AbstractExchange<T>>

Overrides:

getChildren in class AbstractConfiguredObject<T extends AbstractExchange<T>>

Parameters:

clazz - the class of the children to return

Returns:

the children

getPublishers

public Collection<Publisher> getPublishers()

Specified by:

getPublishers in interface Exchange<T extends AbstractExchange<T>>

deleteBinding

public boolean deleteBinding(String bindingKey,
                             AMQQueue queue)

Specified by:

deleteBinding in interface ExchangeImpl<T extends AbstractExchange<T>>

hasBinding

public boolean hasBinding(String bindingKey,
                          AMQQueue queue)

Specified by:

hasBinding in interface ExchangeImpl<T extends AbstractExchange<T>>

createBinding

public Binding createBinding(String bindingKey,
                             Queue queue,
                             Map<String,Object> bindingArguments,
                             Map<String,Object> attributes)

Specified by:

createBinding in interface Exchange<T extends AbstractExchange<T>>