Class AMQPBridgeToQueuePolicyManager

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

All Implemented Interfaces:

ActiveMQServerBasePlugin, ActiveMQServerQueuePlugin

public class AMQPBridgeToQueuePolicyManager
extends AMQPBridgeToPolicyManager
implements ActiveMQServerQueuePlugin

AMQP Bridge policy manager that tracks local queues that match the policy configurations and creates senders to the remote peer for that address until such time as the queue 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
AMQPBridgeToQueuePolicyManager(AMQPBridgeManager bridge, AMQPBridgeMetrics metrics, AMQPBridgeQueuePolicy policy)

Method Summary

Modifier and Type	Method	Description
void	afterCreateQueue(org.apache.activemq.artemis.core.server.Queue queue)
void	afterDestroyQueue(org.apache.activemq.artemis.core.server.Queue queue, SimpleString address, org.apache.activemq.artemis.core.security.SecurityAuth session, boolean checkConsumerCount, boolean removeConsumers, boolean autoDeleteAddress)
protected final void	checkQueueForMatch(org.apache.activemq.artemis.core.server.Queue queue)
AMQPBridgeQueuePolicy	getPolicy()	Returns the policy that defines the bridged queue 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 ActiveMQServerBasePlugin

init, registered, setInit, unregistered

Methods inherited from interface ActiveMQServerQueuePlugin

afterExpiryScan, beforeCreateQueue, beforeCreateQueue, beforeDestroyQueue, beforeDestroyQueue, beforeExpiryScan

Constructor Details

AMQPBridgeToQueuePolicyManager

public AMQPBridgeToQueuePolicyManager(AMQPBridgeManager bridge,
 AMQPBridgeMetrics metrics,
 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: 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

afterCreateQueue

public void afterCreateQueue(org.apache.activemq.artemis.core.server.Queue queue)
                      throws ActiveMQException

Specified by:

afterCreateQueue in interface ActiveMQServerQueuePlugin

Throws:

ActiveMQException

afterDestroyQueue

public void afterDestroyQueue(org.apache.activemq.artemis.core.server.Queue queue,
 SimpleString address,
 org.apache.activemq.artemis.core.security.SecurityAuth session,
 boolean checkConsumerCount,
 boolean removeConsumers,
 boolean autoDeleteAddress)
                       throws ActiveMQException

Specified by:

afterDestroyQueue in interface ActiveMQServerQueuePlugin

Throws:

ActiveMQException

checkQueueForMatch

protected final void checkQueueForMatch(org.apache.activemq.artemis.core.server.Queue queue)