Package org.apache.activemq.artemis.core.postoffice.impl

Class WildcardAddressManager

java.lang.Object

org.apache.activemq.artemis.core.postoffice.impl.SimpleAddressManager

org.apache.activemq.artemis.core.postoffice.impl.WildcardAddressManager

All Implemented Interfaces:

AddressManager

public class WildcardAddressManager
extends SimpleAddressManager

extends the simple manager to allow wildcard addresses to be used.

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.postoffice.impl.SimpleAddressManager

mappings, metricsManager, wildcardConfiguration

Constructor Summary

Constructors

Constructor	Description
WildcardAddressManager(BindingsFactory bindingsFactory, WildcardConfiguration wildcardConfiguration, StorageManager storageManager, MetricsManager metricsManager)
WildcardAddressManager(BindingsFactory bindingsFactory, StorageManager storageManager, MetricsManager metricsManager)

Method Summary

Modifier and Type	Method	Description
boolean	addBinding(Binding binding)	If the address to add the binding to contains a wildcard then a copy of the binding (with the same underlying queue) will be added to matching addresses.
protected void	bindingsEmpty(SimpleString realAddress, Bindings bindings)
void	clear()
AddressMap<Bindings>	getAddressMap()
Bindings	getBindingsForRoutingAddress(SimpleString address)
Binding	removeBinding(SimpleString uniqueName, Transaction tx)	This will use a Transaction as we need to confirm the queue was removed

Methods inherited from class org.apache.activemq.artemis.core.postoffice.impl.SimpleAddressManager

addAddressInfo, addMappingInternal, addMappingsInternal, checkAutoRemoveAddress, findLocalBinding, getAddresses, getAddressInfo, getBinding, getBindings, getDirectBindings, getExistingBindingsForRoutingAddress, getMatchingBindings, getMatchingQueue, getMatchingQueue, reloadAddressInfo, removeAddressInfo, removeBindingInternal, scanAddresses, updateAddressInfo

Methods inherited from class java.lang.Object

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

Constructor Details

WildcardAddressManager

public WildcardAddressManager(BindingsFactory bindingsFactory,
 WildcardConfiguration wildcardConfiguration,
 StorageManager storageManager,
 MetricsManager metricsManager)

WildcardAddressManager

public WildcardAddressManager(BindingsFactory bindingsFactory,
 StorageManager storageManager,
 MetricsManager metricsManager)

Method Details

getBindingsForRoutingAddress

public Bindings getBindingsForRoutingAddress(SimpleString address)
                                      throws Exception

Specified by:

getBindingsForRoutingAddress in interface AddressManager

Overrides:

getBindingsForRoutingAddress in class SimpleAddressManager

Throws:

Exception

addBinding

public boolean addBinding(Binding binding)
                   throws Exception

If the address to add the binding to contains a wildcard then a copy of the binding (with the same underlying queue) will be added to matching addresses. If the address is non wildcard, then we need to add any existing matching wildcard bindings to this address the first time we see it.

Specified by:

addBinding in interface AddressManager

Overrides:

addBinding in class SimpleAddressManager

Parameters:

binding - the binding to add

Returns:

true if the address was a new mapping

Throws:

Exception

removeBinding

public Binding removeBinding(SimpleString uniqueName,
 Transaction tx)
                      throws Exception

Description copied from interface: AddressManager

This will use a Transaction as we need to confirm the queue was removed

Specified by:

removeBinding in interface AddressManager

Overrides:

removeBinding in class SimpleAddressManager

Throws:

Exception

bindingsEmpty

protected void bindingsEmpty(SimpleString realAddress,
 Bindings bindings)

Overrides:

bindingsEmpty in class SimpleAddressManager

clear

public void clear()

Specified by:

clear in interface AddressManager

Overrides:

clear in class SimpleAddressManager

getAddressMap

public AddressMap<Bindings> getAddressMap()