Class AMQPFederationAddressPolicyManager

java.lang.Object

org.apache.activemq.artemis.protocol.amqp.connect.federation.AMQPFederationPolicyManager

org.apache.activemq.artemis.protocol.amqp.connect.federation.AMQPFederationLocalPolicyManager

org.apache.activemq.artemis.protocol.amqp.connect.federation.AMQPFederationAddressPolicyManager

All Implemented Interfaces:

ActiveMQServerAddressPlugin, ActiveMQServerBasePlugin, ActiveMQServerBindingPlugin

public final class AMQPFederationAddressPolicyManager
extends AMQPFederationLocalPolicyManager
implements ActiveMQServerAddressPlugin

The AMQP Federation implementation of an federation address policy manager.

Nested Class Summary

Nested classes/interfaces inherited from class AMQPFederationPolicyManager

AMQPFederationPolicyManager.State

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<String, org.apache.activemq.artemis.protocol.amqp.connect.federation.AMQPFederationAddressPolicyManager.AMQPFederationAddressConsumerRegistry>	addressTracking
protected final String	baseConsumerFilter
protected final Map<org.apache.activemq.artemis.core.postoffice.impl.DivertBinding, Set<org.apache.activemq.artemis.core.postoffice.QueueBinding>>	divertsTracking
protected final FederationReceiveFromAddressPolicy	policy

Fields inherited from class AMQPFederationLocalPolicyManager

configuration

Fields inherited from class AMQPFederationPolicyManager

connected, federation, metrics, policyName, policyType, server, session, state

Constructor Summary

Constructors

Constructor	Description
AMQPFederationAddressPolicyManager(AMQPFederation federation, AMQPFederationMetrics metrics, FederationReceiveFromAddressPolicy addressPolicy)

Method Summary

Modifier and Type	Method	Description
void	afterAddAddress(org.apache.activemq.artemis.core.server.impl.AddressInfo addressInfo, boolean reload)
void	afterAddBinding(org.apache.activemq.artemis.core.postoffice.Binding binding)
void	afterRemoveAddress(SimpleString address, org.apache.activemq.artemis.core.server.impl.AddressInfo addressInfo)
void	afterRemoveBinding(org.apache.activemq.artemis.core.postoffice.Binding binding, org.apache.activemq.artemis.core.transaction.Transaction tx, boolean deleteData)
FederationReceiveFromAddressPolicy	getPolicy()	Returns the immutable federation policy configuration that backs this manager.
protected void	safeCleanupManagerResources(boolean force)	The subclass implements this method and should remove all tracked federation consumer data and also close all consumers either by first safely stopping the consumer or if offline simply closing the consumer.
protected void	scanAllBindings()	Scans all bindings and push them through the normal bindings checks that would be done on an add.
protected void	updateStateAfterConnect(AMQPFederationConsumerConfiguration configuration, AMQPSessionContext session)	Allows the policy manager implementation to update internal state after (re)connection and before the policy manager triggers a scan of all bindings to check for existing or new demand.

Methods inherited from class AMQPFederationLocalPolicyManager

getConfiguration, handleConnectionInterrupted, handleConnectionRestored, handleManagerInitialized, handleManagerShutdown, handleManagerStarted, handleManagerStopped, isPluginBlockingFederationConsumerCreate, isPluginBlockingFederationConsumerCreate, isPluginBlockingFederationConsumerCreate, signalPluginAfterCloseFederationConsumer, signalPluginAfterCreateFederationConsumer, signalPluginBeforeCloseFederationConsumer, signalPluginBeforeCreateFederationConsumer, tryCloseFederationConsumer

Methods inherited from class AMQPFederationPolicyManager

connectionInterrupted, connectionRestored, failIfShutdown, getFederation, getMetrics, getPolicyName, getPolicyType, initialize, isActive, isConnected, isStarted, shutdown, start, stop

Methods inherited from class Object

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

Methods inherited from interface ActiveMQServerAddressPlugin

afterUpdateAddress, beforeAddAddress, beforeRemoveAddress, beforeUpdateAddress

Methods inherited from interface ActiveMQServerBasePlugin

init, registered, setInit, unregistered

Methods inherited from interface ActiveMQServerBindingPlugin

beforeAddBinding, beforeRemoveBinding

Field Details

baseConsumerFilter

protected final String baseConsumerFilter

policy

protected final FederationReceiveFromAddressPolicy policy

addressTracking

protected final Map<String, org.apache.activemq.artemis.protocol.amqp.connect.federation.AMQPFederationAddressPolicyManager.AMQPFederationAddressConsumerRegistry> addressTracking

divertsTracking

protected final Map<org.apache.activemq.artemis.core.postoffice.impl.DivertBinding, Set<org.apache.activemq.artemis.core.postoffice.QueueBinding>> divertsTracking

Constructor Details

AMQPFederationAddressPolicyManager

public AMQPFederationAddressPolicyManager(AMQPFederation federation,
 AMQPFederationMetrics metrics,
 FederationReceiveFromAddressPolicy addressPolicy)
                                   throws ActiveMQException

Throws:

ActiveMQException

Method Details

getPolicy

public FederationReceiveFromAddressPolicy getPolicy()

Description copied from class: AMQPFederationLocalPolicyManager

Returns the immutable federation policy configuration that backs this manager.

Specified by:

getPolicy in class AMQPFederationLocalPolicyManager

Returns:

the receive from address policy that backs the address policy manager

updateStateAfterConnect

protected void updateStateAfterConnect(AMQPFederationConsumerConfiguration configuration,
 AMQPSessionContext session)

Description copied from class: AMQPFederationLocalPolicyManager

Allows the policy manager implementation to update internal state after (re)connection and before the policy manager triggers a scan of all bindings to check for existing or new demand.

Specified by:

updateStateAfterConnect in class AMQPFederationLocalPolicyManager

Parameters:

configuration - The updated configuration based on the current connection.

session - The session that matches the current connection.

safeCleanupManagerResources

protected void safeCleanupManagerResources(boolean force)

Description copied from class: AMQPFederationLocalPolicyManager

The subclass implements this method and should remove all tracked federation consumer data and also close all consumers either by first safely stopping the consumer or if offline simply closing the consumer. If the force flag is set to true the implementation should close the consumer without attempting to stop it by draining link credit before the close.

Specified by:

safeCleanupManagerResources in class AMQPFederationLocalPolicyManager

Parameters:

force - Should the implementation simply close the consumers without attempting a stop.

afterRemoveAddress

public void afterRemoveAddress(SimpleString address,
 org.apache.activemq.artemis.core.server.impl.AddressInfo addressInfo)
                        throws ActiveMQException

Specified by:

afterRemoveAddress in interface ActiveMQServerAddressPlugin

Throws:

ActiveMQException

afterRemoveBinding

public void afterRemoveBinding(org.apache.activemq.artemis.core.postoffice.Binding binding,
 org.apache.activemq.artemis.core.transaction.Transaction tx,
 boolean deleteData)
                        throws ActiveMQException

Specified by:

afterRemoveBinding in interface ActiveMQServerBindingPlugin

Throws:

ActiveMQException

scanAllBindings

protected void scanAllBindings()

Description copied from class: AMQPFederationLocalPolicyManager

Scans all bindings and push them through the normal bindings checks that would be done on an add. This allows for checks on demand after a start or after a connection is restored.

Specified by:

scanAllBindings in class AMQPFederationLocalPolicyManager

afterAddAddress

public void afterAddAddress(org.apache.activemq.artemis.core.server.impl.AddressInfo addressInfo,
 boolean reload)

Specified by:

afterAddAddress in interface ActiveMQServerAddressPlugin

afterAddBinding

public void afterAddBinding(org.apache.activemq.artemis.core.postoffice.Binding binding)

Specified by:

afterAddBinding in interface ActiveMQServerBindingPlugin