Class AMQPBridgeFromAddressPolicyManager

java.lang.Object

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

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

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

All Implemented Interfaces:

ActiveMQServerAddressPlugin, ActiveMQServerBasePlugin, ActiveMQServerBindingPlugin

public final class AMQPBridgeFromAddressPolicyManager
extends AMQPBridgeFromPolicyManager
implements ActiveMQServerAddressPlugin

AMQP Bridge policy manager that tracks local addresses that match the policy configurations for local demand and creates receivers to the remote peer.

Nested Class Summary

Nested classes/interfaces inherited from class AMQPBridgePolicyManager

AMQPBridgePolicyManager.State

Field Summary

Fields inherited from class AMQPBridgeFromPolicyManager

configuration

Fields inherited from class AMQPBridgePolicyManager

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

Constructor Summary

Constructors

Constructor	Description
AMQPBridgeFromAddressPolicyManager(AMQPBridgeManager bridge, AMQPBridgeMetrics metrics, AMQPBridgeAddressPolicy 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)
AMQPBridgeAddressPolicy	getPolicy()	Returns the AMQPBridgePolicy that configured this policy manager.
protected void	safeCleanupManagerResources(boolean force)	The subclass implements this method and should remove all tracked AMQP bridge resource data and also close all links either by first safely stopping the link or if offline simply closing the 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 AMQPBridgeFromPolicyManager

handleConnectionInterrupted, handleConnectionRestored, handleManagerInitialized, handleManagerShutdown, handleManagerStarted, handleManagerStopped, tryCloseBridgeReceiver

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

Methods inherited from interface ActiveMQServerBindingPlugin

beforeAddBinding, beforeRemoveBinding

Constructor Details

AMQPBridgeFromAddressPolicyManager

public AMQPBridgeFromAddressPolicyManager(AMQPBridgeManager bridge,
 AMQPBridgeMetrics metrics,
 AMQPBridgeAddressPolicy addressPolicy)

Method Details

getPolicy

public AMQPBridgeAddressPolicy getPolicy()

Description copied from class: AMQPBridgePolicyManager

Returns the AMQPBridgePolicy that configured this policy manager.

Specified by:

getPolicy in class AMQPBridgePolicyManager

Returns:

the AMQPBridgePolicy that configured this policy manager

scanManagedResources

protected void scanManagedResources()

Description copied from class: AMQPBridgeFromPolicyManager

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 AMQPBridgeFromPolicyManager

safeCleanupManagerResources

protected void safeCleanupManagerResources(boolean force)

Description copied from class: AMQPBridgeFromPolicyManager

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

Specified by:

safeCleanupManagerResources in class AMQPBridgeFromPolicyManager

Parameters:

force - Should the implementation simply close the managed links 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

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