Class AMQPBridgeSenderManager

java.lang.Object

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

public abstract class AMQPBridgeSenderManager
extends Object

An abstract base for managing bridge sender instances that manages the existence of a bridge sender both while active and while attempting recovery. All interactions with the sender manager should occur under the lock of the parent manager instance and this manager will perform any asynchronous work with a lock held on the parent manager instance.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AMQPBridgeSenderManager.AMQPBridgeSenderRecoveryHandler

Constructor Summary

Constructors

Constructor	Description
AMQPBridgeSenderManager(AMQPBridgeToPolicyManager policyManager, AMQPBridgeSenderConfiguration configuration)	Create a new bridge sender manager instance.

Method Summary

Modifier and Type	Method	Description
protected abstract AMQPBridgeSender	createBridgeSender()	Creates a new bridge sender that this manager will monitor and maintain.
void	shutdownNow()	An immediate close of the bridge sender and any recovery tasks that might be pending for a disconnected sender instance.
void	start()	An immediate start of the bridge sender which triggers the first sender attach request and then allows for ongoing recovery efforts if configuration allows it.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AMQPBridgeSenderManager

public AMQPBridgeSenderManager(AMQPBridgeToPolicyManager policyManager,
 AMQPBridgeSenderConfiguration configuration)

Create a new bridge sender manager instance.

Parameters:

policyManager - The policy manager that created this instance.

configuration - The configuration that was in force when the manager was created.

Method Details

createBridgeSender

protected abstract AMQPBridgeSender createBridgeSender()

Creates a new bridge sender that this manager will monitor and maintain. The returned sender should be in an initial state ready for this manager to initialize once it is fully configured.

Returns:

a newly create AMQPBridgeSender for use by this manager.

shutdownNow

public void shutdownNow()

An immediate close of the bridge sender and any recovery tasks that might be pending for a disconnected sender instance. The bridge manager should be calling this method with its lock held.

start

public void start()

An immediate start of the bridge sender which triggers the first sender attach request and then allows for ongoing recovery efforts if configuration allows it. The bridge manager should be calling this method with its lock held.