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