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

Interface AddressManager

All Known Implementing Classes:

SimpleAddressManager, WildcardAddressManager

public interface AddressManager

Used to maintain addresses and BindingsImpl.

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)
boolean	checkAutoRemoveAddress(AddressInfo addressInfo, AddressSettings settings, boolean ignoreDelay)
void	clear()
LocalQueueBinding	findLocalBinding(long id)
Set<SimpleString>	getAddresses()
AddressInfo	getAddressInfo(SimpleString address)
Binding	getBinding(SimpleString queueName)
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
void	scanAddresses(MirrorController mirrorController)
AddressInfo	updateAddressInfo(SimpleString addressName, EnumSet<RoutingType> routingTypes)	Update the specified AddressInfo

Method Details

addBinding

boolean addBinding(Binding binding)
            throws Exception

Throws:

Exception

removeBinding

Binding removeBinding(SimpleString uniqueName,
 Transaction tx)
               throws Exception

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

Throws:

Exception

getExistingBindingsForRoutingAddress

Bindings getExistingBindingsForRoutingAddress(SimpleString address)
                                       throws Exception

Throws:

Exception

getBindingsForRoutingAddress

Bindings getBindingsForRoutingAddress(SimpleString address)
                               throws Exception

Throws:

Exception

getMatchingBindings

Collection<Binding> getMatchingBindings(SimpleString address)
                                 throws Exception

Throws:

Exception

getDirectBindings

Collection<Binding> getDirectBindings(SimpleString address)
                               throws Exception

Throws:

Exception

getMatchingQueue

SimpleString getMatchingQueue(SimpleString address,
 RoutingType routingType)
                       throws Exception

Throws:

Exception

getMatchingQueue

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

Throws:

Exception

findLocalBinding

LocalQueueBinding findLocalBinding(long id)

clear

void clear()

getBinding

Binding getBinding(SimpleString queueName)

getBindings

Stream<Binding> getBindings()

getAddresses

Set<SimpleString> getAddresses()

addAddressInfo

boolean addAddressInfo(AddressInfo addressInfo)
                throws Exception

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

Returns:

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

Throws:

Exception

reloadAddressInfo

boolean reloadAddressInfo(AddressInfo addressInfo)
                   throws Exception

Throws:

Exception

updateAddressInfo

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

Update the specified AddressInfo

Returns:

the updated AddressInfo or null if there are no updates

Throws:

Exception - if the address doesn't exist

removeAddressInfo

AddressInfo removeAddressInfo(SimpleString address)
                       throws Exception

Throws:

Exception

getAddressInfo

AddressInfo getAddressInfo(SimpleString address)

scanAddresses

void scanAddresses(MirrorController mirrorController)
            throws Exception

Throws:

Exception

checkAutoRemoveAddress

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

Throws:

Exception