org.apache.qpid.server.exchange

Class FanoutExchange

java.lang.Object

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

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

org.apache.qpid.server.exchange.FanoutExchange

All Implemented Interfaces:

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

public class FanoutExchange
extends AbstractExchange<FanoutExchange>

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
FanoutExchange(Map<String,Object> attributes, VirtualHostImpl vhost)

Method Summary

Modifier and Type	Method and Description
ArrayList<BaseQueue>	doRoute(ServerMessage payload, String routingKey, InstanceProperties instanceProperties)
protected void	onBind(BindingImpl binding)
protected void	onBindingUpdated(BindingImpl binding, Map<String,Object> oldArguments)
protected void	onUnbind(BindingImpl binding)

Methods inherited from class org.apache.qpid.server.exchange.AbstractExchange

addBinding, addBinding, addBindingListener, addCloseTask, addReference, createBinding, deleteBinding, doAddBinding, doRemoveBinding, getAlternateExchange, getArguments, getBinding, getBindingCount, getBindingCountHigh, getBindings, getByteRoutes, getBytesDropped, getBytesIn, getChildren, getEventLogger, getMessagesDropped, getMessagesIn, getMsgRoutes, getPublishers, getVirtualHost, hasBinding, hasBindings, hasReferrers, isAutoDelete, isBound, isBound, isBound, isBound, isBound, isBound, isBound, onOpen, onValidate, removeBindingAsync, removeBindingListener, removeCloseTask, removeReference, replaceBinding, send, 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

FanoutExchange

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

Method Detail

doRoute

public ArrayList<BaseQueue> doRoute(ServerMessage payload,
                                    String routingKey,
                                    InstanceProperties instanceProperties)

Specified by:

doRoute in class AbstractExchange<FanoutExchange>

onBindingUpdated

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

Specified by:

onBindingUpdated in class AbstractExchange<FanoutExchange>

onBind

protected void onBind(BindingImpl binding)

Specified by:

onBind in class AbstractExchange<FanoutExchange>

onUnbind

protected void onUnbind(BindingImpl binding)

Specified by:

onUnbind in class AbstractExchange<FanoutExchange>