Class AMQPBridgeManagers

java.lang.Object

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

public class AMQPBridgeManagers
extends Object

Simple AMQP Bridge aggregation tool used to simplify broker connection management of multiple bridges

Constructor Summary

Constructors

Constructor	Description
AMQPBridgeManagers(AMQPBrokerConnection brokerConnection)

Method Summary

Modifier and Type	Method	Description
void	addBridgeManager(AMQPBridgeBrokerConnectionElement configuration)	Adds a new bridge to the collection of managed bridges and starts the new AMQPBridgeManager
void	connectionInterrupted()	Signals all bridges that the current connection has dropped, exceptions are ignored.
void	connectionRestored(AMQPSessionContext session)	Signal all bridge managers that the connection has been restored
void	shutdown()	Shutdown all bridge managers ignoring any thrown exceptions and clears state from all previously registered manager, new managers can be added after a reset.
void	start()	Starts each bridge manager registered in the managers collection.
void	stop()	Stops each bridge manager registered in the managers collection.

Methods inherited from class Object

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

Constructor Details

AMQPBridgeManagers

public AMQPBridgeManagers(AMQPBrokerConnection brokerConnection)

Method Details

shutdown

public void shutdown()

Shutdown all bridge managers ignoring any thrown exceptions and clears state from all previously registered manager, new managers can be added after a reset.

start

public void start()
           throws Exception

Starts each bridge manager registered in the managers collection.

Throws:

Exception - if an error occurs while starting any bridge manager.

stop

public void stop()
          throws Exception

Stops each bridge manager registered in the managers collection.

Throws:

Exception - if an error occurs while stopping any bridge manager.

addBridgeManager

public void addBridgeManager(AMQPBridgeBrokerConnectionElement configuration)
                      throws ActiveMQException

Adds a new bridge to the collection of managed bridges and starts the new AMQPBridgeManager

Parameters:

configuration - The configuration to use when creating a new bridge manager.

Throws:

ActiveMQException

connectionRestored

public void connectionRestored(AMQPSessionContext session)
                        throws ActiveMQException

Signal all bridge managers that the connection has been restored

Parameters:

session - The session in which the bridge manager resources will reside.

Throws:

ActiveMQException - if an error occurs during connection restoration.

connectionInterrupted

public void connectionInterrupted()

Signals all bridges that the current connection has dropped, exceptions are ignored.