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.

Constructor Summary

Constructors

Constructor and Description
SimpleAddressManager(BindingsFactory bindingsFactory)

Method Summary

Modifier and Type	Method and Description
boolean	addBinding(Binding binding)
protected boolean	addMappingInternal(SimpleString address, Binding binding)
void	clear()
Set<SimpleString>	getAddresses()
Binding	getBinding(SimpleString bindableName)
Map<SimpleString,Binding>	getBindings()
Bindings	getBindingsForRoutingAddress(SimpleString address)
Bindings	getMatchingBindings(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)
protected Binding	removeMapping(SimpleString bindableName, Bindings bindings)

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleAddressManager

public SimpleAddressManager(BindingsFactory bindingsFactory)

Method Detail

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

Returns:

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 Map<SimpleString,Binding> getBindings()

Specified by:

getBindings in interface AddressManager

getMatchingBindings

public Bindings getMatchingBindings(SimpleString address)
                             throws Exception

Specified by:

getMatchingBindings 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)

removeMapping

protected Binding removeMapping(SimpleString bindableName,
                                Bindings bindings)

addMappingInternal

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

Throws:

Exception