Class AMQPBridgeReceiverManager.AMQPBridgeReceiverRecoveryHandler

java.lang.Object

org.apache.activemq.artemis.protocol.amqp.connect.bridge.AMQPBridgeReceiverManager.AMQPBridgeReceiverRecoveryHandler

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

AMQPBridgeReceiverManager<E>

public static class AMQPBridgeReceiverManager.AMQPBridgeReceiverRecoveryHandler
extends Object
implements Closeable

Constructor Summary

Constructors

Constructor	Description
AMQPBridgeReceiverRecoveryHandler(AMQPBridgeReceiverManager<?> manager, AMQPBridgeLinkConfiguration configuration)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	tryScheduleNextRecovery(ScheduledExecutorService scheduler)	When a link used by the bridge fails, this method is used to try and schedule a new connection attempt if the configuration rules allow one.

Methods inherited from class Object

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

Constructor Details

AMQPBridgeReceiverRecoveryHandler

public AMQPBridgeReceiverRecoveryHandler(AMQPBridgeReceiverManager<?> manager,
 AMQPBridgeLinkConfiguration configuration)

Method Details

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

tryScheduleNextRecovery

public boolean tryScheduleNextRecovery(ScheduledExecutorService scheduler)

When a link used by the bridge fails, this method is used to try and schedule a new connection attempt if the configuration rules allow one. If the configuration does not allow any (more) reconnection attempts this method returns false.

Parameters:

scheduler - The scheduler to use to schedule the next connection attempt.

Returns:

true if an attempt was scheduled or false if no attempts are allowed.