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

Class SimpleAddressManager

java.lang.Object

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

All Implemented Interfaces:

AddressManager

Direct Known Subclasses:

WildcardAddressManager

public class SimpleAddressManager
extends Object
implements AddressManager

A simple address manager that maintains the addresses and bindings.

Field Summary

Fields

Modifier and Type	Field	Description
protected final ConcurrentMap<SimpleString,Bindings>	mappings
protected final MetricsManager	metricsManager
protected final WildcardConfiguration	wildcardConfiguration

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
boolean	addAddressInfo(AddressInfo addressInfo)	Returns true if the address was added, false if it wasn't added.
boolean	addBinding(Binding binding)
protected boolean	addMappingInternal(SimpleString address, Binding binding)
protected Bindings	addMappingsInternal(SimpleString address, Collection<Binding> newBindings)
protected void	bindingsEmpty(SimpleString realAddress, Bindings bindings)
boolean	checkAutoRemoveAddress(AddressInfo addressInfo, AddressSettings settings, boolean ignoreDelay)
void	clear()
LocalQueueBinding	findLocalBinding(long bindingID)
Set<SimpleString>	getAddresses()
AddressInfo	getAddressInfo(SimpleString addressName)
Binding	getBinding(SimpleString bindableName)
Stream<Binding>	getBindings()
Bindings	getBindingsForRoutingAddress(SimpleString address)
Collection<Binding>	getDirectBindings(SimpleString address)
Bindings	getExistingBindingsForRoutingAddress(SimpleString address)
Collection<Binding>	getMatchingBindings(SimpleString address)
SimpleString	getMatchingQueue(SimpleString address, RoutingType routingType)
SimpleString	getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType)
boolean	reloadAddressInfo(AddressInfo addressInfo)
AddressInfo	removeAddressInfo(SimpleString address)
Binding	removeBinding(SimpleString uniqueName, Transaction tx)	This will use a Transaction as we need to confirm the queue was removed
protected void	removeBindingInternal(SimpleString address, SimpleString bindableName)
void	scanAddresses(MirrorController mirrorController)
AddressInfo	updateAddressInfo(SimpleString addressName, EnumSet<RoutingType> routingTypes)	Update the specified AddressInfo

Methods inherited from class java.lang.Object

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

Field Details

mappings

protected final ConcurrentMap<SimpleString,Bindings> mappings

metricsManager

protected final MetricsManager metricsManager

wildcardConfiguration

protected final WildcardConfiguration wildcardConfiguration

Constructor Details

SimpleAddressManager

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

SimpleAddressManager

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

Method Details

findLocalBinding

public LocalQueueBinding findLocalBinding(long bindingID)

Specified by:

findLocalBinding in interface AddressManager

addBinding

public boolean addBinding(Binding binding)
                   throws Exception

Specified by:

addBinding in interface AddressManager

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

Throws:

Exception

getExistingBindingsForRoutingAddress

public Bindings getExistingBindingsForRoutingAddress(SimpleString address)
                                              throws Exception

Specified by:

getExistingBindingsForRoutingAddress in interface AddressManager

Throws:

Exception

getBindingsForRoutingAddress

public Bindings getBindingsForRoutingAddress(SimpleString address)
                                      throws Exception

Specified by:

getBindingsForRoutingAddress in interface AddressManager

Throws:

Exception

getBinding

public Binding getBinding(SimpleString bindableName)

Specified by:

getBinding in interface AddressManager

getBindings

public Stream<Binding> getBindings()

Specified by:

getBindings in interface AddressManager

getMatchingBindings

public Collection<Binding> getMatchingBindings(SimpleString address)
                                        throws Exception

Specified by:

getMatchingBindings in interface AddressManager

Throws:

Exception

getDirectBindings

public Collection<Binding> getDirectBindings(SimpleString address)
                                      throws Exception

Specified by:

getDirectBindings in interface AddressManager

Throws:

Exception

getMatchingQueue

public SimpleString getMatchingQueue(SimpleString address,
 RoutingType routingType)
                              throws Exception

Specified by:

getMatchingQueue in interface AddressManager

Throws:

Exception

getMatchingQueue

public SimpleString getMatchingQueue(SimpleString address,
 SimpleString queueName,
 RoutingType routingType)
                              throws Exception

Specified by:

getMatchingQueue in interface AddressManager

Throws:

Exception

clear

public void clear()

Specified by:

clear in interface AddressManager

getAddresses

public Set<SimpleString> getAddresses()

Specified by:

getAddresses in interface AddressManager

removeBindingInternal

protected void removeBindingInternal(SimpleString address,
 SimpleString bindableName)

bindingsEmpty

protected void bindingsEmpty(SimpleString realAddress,
 Bindings bindings)

addMappingsInternal

protected Bindings addMappingsInternal(SimpleString address,
 Collection<Binding> newBindings)
                                throws Exception

Throws:

Exception

addMappingInternal

protected boolean addMappingInternal(SimpleString address,
 Binding binding)
                              throws Exception

Throws:

Exception

reloadAddressInfo

public boolean reloadAddressInfo(AddressInfo addressInfo)

Specified by:

reloadAddressInfo in interface AddressManager

addAddressInfo

public boolean addAddressInfo(AddressInfo addressInfo)
                       throws Exception

Description copied from interface: AddressManager

Returns true if the address was added, false if it wasn't added.

Specified by:

addAddressInfo in interface AddressManager

Returns:

true if the address was added, false if it wasn't added

Throws:

Exception

updateAddressInfo

public AddressInfo updateAddressInfo(SimpleString addressName,
 EnumSet<RoutingType> routingTypes)
                              throws Exception

Description copied from interface: AddressManager

Update the specified AddressInfo

Specified by:

updateAddressInfo in interface AddressManager

Returns:

the updated AddressInfo or null if there are no updates

Throws:

Exception - if the address doesn't exist

checkAutoRemoveAddress

public boolean checkAutoRemoveAddress(AddressInfo addressInfo,
 AddressSettings settings,
 boolean ignoreDelay)
                               throws Exception

Specified by:

checkAutoRemoveAddress in interface AddressManager

Throws:

Exception

removeAddressInfo

public AddressInfo removeAddressInfo(SimpleString address)
                              throws Exception

Specified by:

removeAddressInfo in interface AddressManager

Throws:

Exception

getAddressInfo

public AddressInfo getAddressInfo(SimpleString addressName)

Specified by:

getAddressInfo in interface AddressManager

scanAddresses

public void scanAddresses(MirrorController mirrorController)
                   throws Exception

Specified by:

scanAddresses in interface AddressManager

Throws:

Exception