Class AMQPBridgeToPolicyManager

java.lang.Object

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

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

All Implemented Interfaces:

ActiveMQServerBasePlugin

Direct Known Subclasses:

AMQPBridgeToAddressPolicyManager, AMQPBridgeToQueuePolicyManager

public abstract class AMQPBridgeToPolicyManager
extends AMQPBridgePolicyManager
implements ActiveMQServerBasePlugin

Base class for AMQP bridge policy managers that bridge to the remote peer from this peer for some configured resource.

Nested Class Summary

Nested classes/interfaces inherited from class AMQPBridgePolicyManager

AMQPBridgePolicyManager.State

Field Summary

Fields

Modifier and Type	Field	Description
protected AMQPBridgeSenderConfiguration	configuration

Fields inherited from class AMQPBridgePolicyManager

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

Constructor Summary

Constructors

Constructor	Description
AMQPBridgeToPolicyManager(AMQPBridgeManager bridge, AMQPBridgeMetrics metrics, String policyName, AMQPBridgeType policyType)

Method Summary

Modifier and Type	Method	Description
protected void	handleConnectionInterrupted()	On connection interrupted a bridge policy manager needs to perform any specific actions to pause of cleanup current resources based on the connection being closed.
protected void	handleConnectionRestored(AMQPBridgeConfiguration configuration)	On connection restoration a bridge policy manager needs to perform any specific actions to resume service based on a new connection having been established.
protected void	handleManagerInitialized()	On initialize a bridge policy manager needs to perform any specific initialization actions it requires to begin tracking broker resources.
protected void	handleManagerShutdown()	On shutdown a bridge policy manager needs to perform any specific shutdown actions it requires to cease tracking broker resources.
protected void	handleManagerStarted()	On start a bridge policy manager needs to perform any specific startup actions it requires to begin tracking broker resources.
protected void	handleManagerStopped()	On stop a bridge policy manager needs to perform any specific stopped actions it requires to cease tracking broker resources and cleanup.
protected abstract void	safeCleanupManagerResources()	The subclass implements this method and should remove all tracked AMQP bridge resource data and also close all links immediately.
protected abstract void	scanManagedResources()	Scans all server resources and push them through the normal checks that would be done on an add.

Methods inherited from class AMQPBridgePolicyManager

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

init, registered, setInit, unregistered

Field Details

configuration

protected volatile AMQPBridgeSenderConfiguration configuration

Constructor Details

AMQPBridgeToPolicyManager

public AMQPBridgeToPolicyManager(AMQPBridgeManager bridge,
 AMQPBridgeMetrics metrics,
 String policyName,
 AMQPBridgeType policyType)

Method Details

handleManagerInitialized

protected void handleManagerInitialized()

Description copied from class: AMQPBridgePolicyManager

On initialize a bridge policy manager needs to perform any specific initialization actions it requires to begin tracking broker resources.

Specified by:

handleManagerInitialized in class AMQPBridgePolicyManager

handleManagerStarted

protected void handleManagerStarted()

Description copied from class: AMQPBridgePolicyManager

On start a bridge policy manager needs to perform any specific startup actions it requires to begin tracking broker resources.

Specified by:

handleManagerStarted in class AMQPBridgePolicyManager

handleManagerStopped

protected void handleManagerStopped()

Description copied from class: AMQPBridgePolicyManager

On stop a bridge policy manager needs to perform any specific stopped actions it requires to cease tracking broker resources and cleanup.

Specified by:

handleManagerStopped in class AMQPBridgePolicyManager

handleManagerShutdown

protected void handleManagerShutdown()

Description copied from class: AMQPBridgePolicyManager

On shutdown a bridge policy manager needs to perform any specific shutdown actions it requires to cease tracking broker resources.

Specified by:

handleManagerShutdown in class AMQPBridgePolicyManager

handleConnectionInterrupted

protected void handleConnectionInterrupted()

Description copied from class: AMQPBridgePolicyManager

On connection interrupted a bridge policy manager needs to perform any specific actions to pause of cleanup current resources based on the connection being closed.

Specified by:

handleConnectionInterrupted in class AMQPBridgePolicyManager

handleConnectionRestored

protected void handleConnectionRestored(AMQPBridgeConfiguration configuration)

Description copied from class: AMQPBridgePolicyManager

On connection restoration a bridge policy manager needs to perform any specific actions to resume service based on a new connection having been established.

Specified by:

handleConnectionRestored in class AMQPBridgePolicyManager

Parameters:

configuration - The bridge configuration relative to the currently established connection.

scanManagedResources

protected abstract void scanManagedResources()

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.

safeCleanupManagerResources

protected abstract void safeCleanupManagerResources()

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