org.apache.synapse.transport.amqp.ha

Class AMQPTransportReconnectHandler

java.lang.Object

org.apache.synapse.transport.amqp.ha.AMQPTransportReconnectHandler

All Implemented Interfaces:

Runnable

public class AMQPTransportReconnectHandler
extends Object
implements Runnable

Responsible for handling the shutdown signals gracefully. For example this provides the functionality for reconnecting to broker if broker when offline. The reconnection attempts happens in exponential back-off fashion.

Constructor Summary

Constructors

Constructor and Description
AMQPTransportReconnectHandler(ExecutorService es, int maxReconnectionDuration, double reconnectionProgressionFactor, int initialReconnectDuration, AMQPTransportConnectionFactoryManager connectionFactoryManager)

Method Summary

Methods

Modifier and Type	Method and Description
BlockingQueue<AMQPTransportHAEntry>	getBlockedTasks()
ConcurrentMap<String,AMQPTransportHABrokerEntry>	getConnectionMap()
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

AMQPTransportReconnectHandler

public AMQPTransportReconnectHandler(ExecutorService es,
                             int maxReconnectionDuration,
                             double reconnectionProgressionFactor,
                             int initialReconnectDuration,
                             AMQPTransportConnectionFactoryManager connectionFactoryManager)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

getBlockedTasks

public BlockingQueue<AMQPTransportHAEntry> getBlockedTasks()

getConnectionMap

public ConcurrentMap<String,AMQPTransportHABrokerEntry> getConnectionMap()