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
configurationFields inherited from class AMQPBridgePolicyManager
bridge, connected, metrics, policyName, policyType, server, session, state -
Constructor Summary
ConstructorsConstructorDescriptionAMQPBridgeFromAddressPolicyManager(AMQPBridgeManager bridge, AMQPBridgeMetrics metrics, AMQPBridgeAddressPolicy addressPolicy) -
Method Summary
Modifier and TypeMethodDescriptionvoidafterAddAddress(org.apache.activemq.artemis.core.server.impl.AddressInfo addressInfo, boolean reload) voidafterAddBinding(org.apache.activemq.artemis.core.postoffice.Binding binding) voidafterRemoveAddress(SimpleString address, org.apache.activemq.artemis.core.server.impl.AddressInfo addressInfo) voidafterRemoveBinding(org.apache.activemq.artemis.core.postoffice.Binding binding, org.apache.activemq.artemis.core.transaction.Transaction tx, boolean deleteData) Returns theAMQPBridgePolicythat configured this policy manager.protected voidsafeCleanupManagerResources(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 voidScans 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, tryCloseBridgeReceiverMethods inherited from class AMQPBridgePolicyManager
connectionInterrupted, connectionRestored, failIfShutdown, getBridgeManager, getMetrics, getPolicyName, getPolicyType, initialize, isActive, isConnected, isStarted, shutdown, start, stopMethods inherited from class Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface ActiveMQServerAddressPlugin
afterUpdateAddress, beforeAddAddress, beforeRemoveAddress, beforeUpdateAddressMethods inherited from interface ActiveMQServerBasePlugin
init, registered, setInit, unregisteredMethods inherited from interface ActiveMQServerBindingPlugin
beforeAddBinding, beforeRemoveBinding
-
Constructor Details
-
AMQPBridgeFromAddressPolicyManager
public AMQPBridgeFromAddressPolicyManager(AMQPBridgeManager bridge, AMQPBridgeMetrics metrics, AMQPBridgeAddressPolicy addressPolicy)
-
-
Method Details
-
getPolicy
Description copied from class:AMQPBridgePolicyManagerReturns theAMQPBridgePolicythat configured this policy manager.- Specified by:
getPolicyin classAMQPBridgePolicyManager- Returns:
- the
AMQPBridgePolicythat configured this policy manager
-
scanManagedResources
protected void scanManagedResources()Description copied from class:AMQPBridgeFromPolicyManagerScans 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:
scanManagedResourcesin classAMQPBridgeFromPolicyManager
-
safeCleanupManagerResources
protected void safeCleanupManagerResources(boolean force) Description copied from class:AMQPBridgeFromPolicyManagerThe 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:
safeCleanupManagerResourcesin classAMQPBridgeFromPolicyManager- 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:
afterRemoveAddressin interfaceActiveMQServerAddressPlugin- 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:
afterRemoveBindingin interfaceActiveMQServerBindingPlugin- Throws:
ActiveMQException
-
afterAddAddress
public void afterAddAddress(org.apache.activemq.artemis.core.server.impl.AddressInfo addressInfo, boolean reload) - Specified by:
afterAddAddressin interfaceActiveMQServerAddressPlugin
-
afterAddBinding
public void afterAddBinding(org.apache.activemq.artemis.core.postoffice.Binding binding) - Specified by:
afterAddBindingin interfaceActiveMQServerBindingPlugin
-