Class AMQPBridgeFromQueuePolicyManager

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.AMQPBridgeFromQueuePolicyManager

All Implemented Interfaces:

ActiveMQServerBasePlugin, ActiveMQServerBindingPlugin, ActiveMQServerConsumerPlugin

public final class AMQPBridgeFromQueuePolicyManager
extends AMQPBridgeFromPolicyManager
implements ActiveMQServerConsumerPlugin

AMQP Bridge policy manager that tracks local queues that match the policy configurations for local demand and creates consumers to the remote peer configured.

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
AMQPBridgeFromQueuePolicyManager(AMQPBridgeManager bridge, AMQPBridgeMetrics metric, AMQPBridgeQueuePolicy policy)

Method Summary

Modifier and Type	Method	Description
void	afterAddBinding(org.apache.activemq.artemis.core.postoffice.Binding binding)
void	afterCloseConsumer(org.apache.activemq.artemis.core.server.ServerConsumer consumer, boolean failed)
void	afterCreateConsumer(org.apache.activemq.artemis.core.server.ServerConsumer consumer)
void	afterRemoveBinding(org.apache.activemq.artemis.core.postoffice.Binding binding, org.apache.activemq.artemis.core.transaction.Transaction tx, boolean deleteData)
AMQPBridgeQueuePolicy	getPolicy()	Returns the policy that defines the bridged queue this policy manager monitors.
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 ActiveMQServerBasePlugin

init, registered, setInit, unregistered

Methods inherited from interface ActiveMQServerBindingPlugin

beforeAddBinding, beforeRemoveBinding

Methods inherited from interface ActiveMQServerConsumerPlugin

beforeCloseConsumer, beforeCreateConsumer, beforeCreateConsumer

Constructor Details

AMQPBridgeFromQueuePolicyManager

public AMQPBridgeFromQueuePolicyManager(AMQPBridgeManager bridge,
 AMQPBridgeMetrics metric,
 AMQPBridgeQueuePolicy policy)

Method Details

getPolicy

public AMQPBridgeQueuePolicy getPolicy()

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

Specified by:

getPolicy in class AMQPBridgePolicyManager

Returns:

the policy that defines the bridged queue this policy manager monitors

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.

afterCreateConsumer

public void afterCreateConsumer(org.apache.activemq.artemis.core.server.ServerConsumer consumer)

Specified by:

afterCreateConsumer in interface ActiveMQServerConsumerPlugin

afterCloseConsumer

public void afterCloseConsumer(org.apache.activemq.artemis.core.server.ServerConsumer consumer,
 boolean failed)

Specified by:

afterCloseConsumer in interface ActiveMQServerConsumerPlugin

afterAddBinding

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

Specified by:

afterAddBinding in interface ActiveMQServerBindingPlugin

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