public class SimpleAddressManager extends Object implements AddressManager
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<SimpleString,Bindings> |
mappings
HashMap
|
protected MetricsManager |
metricsManager |
protected WildcardConfiguration |
wildcardConfiguration |
Constructor and Description |
---|
SimpleAddressManager(BindingsFactory bindingsFactory,
StorageManager storageManager,
MetricsManager metricsManager) |
SimpleAddressManager(BindingsFactory bindingsFactory,
WildcardConfiguration wildcardConfiguration,
StorageManager storageManager,
MetricsManager metricsManager) |
protected final ConcurrentMap<SimpleString,Bindings> mappings
protected final MetricsManager metricsManager
protected final WildcardConfiguration wildcardConfiguration
public SimpleAddressManager(BindingsFactory bindingsFactory, StorageManager storageManager, MetricsManager metricsManager)
public SimpleAddressManager(BindingsFactory bindingsFactory, WildcardConfiguration wildcardConfiguration, StorageManager storageManager, MetricsManager metricsManager)
public boolean addBinding(Binding binding) throws Exception
addBinding
in interface AddressManager
Exception
public Binding removeBinding(SimpleString uniqueName, Transaction tx) throws Exception
AddressManager
removeBinding
in interface AddressManager
Exception
public Bindings getBindingsForRoutingAddress(SimpleString address) throws Exception
getBindingsForRoutingAddress
in interface AddressManager
Exception
public Binding getBinding(SimpleString bindableName)
getBinding
in interface AddressManager
public Map<SimpleString,Binding> getBindings()
getBindings
in interface AddressManager
public Bindings getMatchingBindings(SimpleString address) throws Exception
getMatchingBindings
in interface AddressManager
Exception
public Bindings getDirectBindings(SimpleString address) throws Exception
getDirectBindings
in interface AddressManager
Exception
public SimpleString getMatchingQueue(SimpleString address, RoutingType routingType) throws Exception
getMatchingQueue
in interface AddressManager
Exception
public SimpleString getMatchingQueue(SimpleString address, SimpleString queueName, RoutingType routingType) throws Exception
getMatchingQueue
in interface AddressManager
Exception
public void clear()
clear
in interface AddressManager
public Set<SimpleString> getAddresses()
getAddresses
in interface AddressManager
protected void removeBindingInternal(SimpleString address, SimpleString bindableName)
protected Binding removeMapping(SimpleString bindableName, Bindings bindings)
protected boolean addMappingInternal(SimpleString address, Binding binding) throws Exception
Exception
public boolean reloadAddressInfo(AddressInfo addressInfo) throws Exception
reloadAddressInfo
in interface AddressManager
Exception
public boolean addAddressInfo(AddressInfo addressInfo) throws Exception
addAddressInfo
in interface AddressManager
Exception
public AddressInfo updateAddressInfo(SimpleString addressName, EnumSet<RoutingType> routingTypes) throws Exception
AddressManager
updateAddressInfo
in interface AddressManager
Exception
public AddressInfo removeAddressInfo(SimpleString address) throws Exception
removeAddressInfo
in interface AddressManager
Exception
public AddressInfo getAddressInfo(SimpleString addressName)
getAddressInfo
in interface AddressManager
public void updateMessageLoadBalancingTypeForAddress(SimpleString address, MessageLoadBalancingType messageLoadBalancingType) throws Exception
updateMessageLoadBalancingTypeForAddress
in interface AddressManager
Exception
Copyright © 2019 JBoss by Red Hat. All rights reserved.