public class HeadersExchange extends AbstractExchange<HeadersExchange>
The Headers Exchange Routes messages according to the value/presence of fields in the message header table. (Basic and JMS content has a content header field called "headers" that is a table of message header fields). class = "headers" routing key is not used Has the following binding arguments: the X-match field - if "all", does an AND match (used for GRM), if "any", does an OR match. other fields prefixed with "X-" are ignored (and generate a console warning message). a field with no value or empty value indicates a match on presence only. a field with a value indicates match on field presence and specific value. Standard instances: amq.match - pub/sub on field content/value
AbstractConfiguredObject.CallableWithArgument<V,A>, AbstractConfiguredObject.ChainedListenableFuture<V>, AbstractConfiguredObject.ChainedSettableFuture<V>, AbstractConfiguredObject.DuplicateIdException, AbstractConfiguredObject.DuplicateNameExceptionExchangeImpl.BindingListenerSECURED_STRING_VALUEALTERNATE_EXCHANGE, CLASS_DESCRIPTIONCONTEXT, 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 |
|---|
HeadersExchange(Map<String,Object> attributes,
VirtualHostImpl vhost) |
| 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) |
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, toStringaddChangeListener, 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, validateOnCreateclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitaddChangeListener, 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, setAttributesAsyncgetNamepublic HeadersExchange(Map<String,Object> attributes, VirtualHostImpl vhost)
public ArrayList<BaseQueue> doRoute(ServerMessage payload, String routingKey, InstanceProperties instanceProperties)
doRoute in class AbstractExchange<HeadersExchange>protected void onBind(BindingImpl binding)
onBind in class AbstractExchange<HeadersExchange>protected void onBindingUpdated(BindingImpl binding, Map<String,Object> oldArguments)
onBindingUpdated in class AbstractExchange<HeadersExchange>protected void onUnbind(BindingImpl binding)
onUnbind in class AbstractExchange<HeadersExchange>Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.