public class DirectExchange extends AbstractExchange<DirectExchange>
AbstractConfiguredObject.CallableWithArgument<V,A>, AbstractConfiguredObject.ChainedListenableFuture<V>, AbstractConfiguredObject.ChainedSettableFuture<V>, AbstractConfiguredObject.DuplicateIdException, AbstractConfiguredObject.DuplicateNameException
ExchangeImpl.BindingListener
SECURED_STRING_VALUE
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
Constructor and Description |
---|
DirectExchange(Map<String,Object> attributes,
VirtualHostImpl vhost) |
Modifier and Type | Method and Description |
---|---|
List<? extends 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) |
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
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
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
getName
public DirectExchange(Map<String,Object> attributes, VirtualHostImpl vhost)
public List<? extends BaseQueue> doRoute(ServerMessage payload, String routingKey, InstanceProperties instanceProperties)
doRoute
in class AbstractExchange<DirectExchange>
protected void onBindingUpdated(BindingImpl binding, Map<String,Object> oldArguments)
onBindingUpdated
in class AbstractExchange<DirectExchange>
protected void onBind(BindingImpl binding)
onBind
in class AbstractExchange<DirectExchange>
protected void onUnbind(BindingImpl binding)
onUnbind
in class AbstractExchange<DirectExchange>
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.