Class AMQPBridgeToAddressPolicyManager

java.lang.Object

org.apache.activemq.artemis.protocol.amqp.connect.bridge.AMQPBridgePolicyManager

org.apache.activemq.artemis.protocol.amqp.connect.bridge.AMQPBridgeToPolicyManager

org.apache.activemq.artemis.protocol.amqp.connect.bridge.AMQPBridgeToAddressPolicyManager

All Implemented Interfaces:

ActiveMQServerAddressPlugin, ActiveMQServerBasePlugin

public class AMQPBridgeToAddressPolicyManager
extends AMQPBridgeToPolicyManager
implements ActiveMQServerAddressPlugin

AMQP Bridge policy manager that tracks local addresses that match the policy configurations and creates senders to the remote peer for that address until such time as the address is removed locally.

Nested Class Summary

Nested classes/interfaces inherited from class AMQPBridgePolicyManager

AMQPBridgePolicyManager.State

Field Summary

Fields inherited from class AMQPBridgeToPolicyManager

configuration

Fields inherited from class AMQPBridgePolicyManager

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

Constructor Summary

Constructors

Constructor	Description
AMQPBridgeToAddressPolicyManager(AMQPBridgeManager bridge, AMQPBridgeMetrics metrics, AMQPBridgeAddressPolicy policy)

Method Summary

Modifier and Type	Method	Description
void	afterAddAddress(org.apache.activemq.artemis.core.server.impl.AddressInfo addressInfo, boolean reload)
void	afterRemoveAddress(SimpleString address, org.apache.activemq.artemis.core.server.impl.AddressInfo addressInfo)
AMQPBridgeAddressPolicy	getPolicy()	Returns the policy that defines the bridged address this policy manager monitors.
protected void	safeCleanupManagerResources()	The subclass implements this method and should remove all tracked AMQP bridge resource data and also close all links immediately.
protected void	scanManagedResources()	Scans all server resources and push them through the normal checks that would be done on an add.

Methods inherited from class AMQPBridgeToPolicyManager

handleConnectionInterrupted, handleConnectionRestored, handleManagerInitialized, handleManagerShutdown, handleManagerStarted, handleManagerStopped

Methods inherited from class AMQPBridgePolicyManager

connectionInterrupted, connectionRestored, failIfShutdown, getBridgeManager, 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

Constructor Details

AMQPBridgeToAddressPolicyManager

public AMQPBridgeToAddressPolicyManager(AMQPBridgeManager bridge,
 AMQPBridgeMetrics metrics,
 AMQPBridgeAddressPolicy policy)

Method Details

getPolicy

public AMQPBridgeAddressPolicy getPolicy()

Returns the policy that defines the bridged address this policy manager monitors.

Specified by:

getPolicy in class AMQPBridgePolicyManager

Returns:

the policy that defines the bridged address this policy manager monitors

scanManagedResources

protected void scanManagedResources()

Description copied from class: AMQPBridgeToPolicyManager

Scans all server resources and push them through the normal 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:

scanManagedResources in class AMQPBridgeToPolicyManager

safeCleanupManagerResources

protected void safeCleanupManagerResources()

Description copied from class: AMQPBridgeToPolicyManager

The subclass implements this method and should remove all tracked AMQP bridge resource data and also close all links immediately.

Specified by:

safeCleanupManagerResources in class AMQPBridgeToPolicyManager

afterAddAddress

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

Specified by:

afterAddAddress in interface ActiveMQServerAddressPlugin

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