org.hornetq.jms.server.recovery

Class RecoveryDiscovery

java.lang.Object

org.hornetq.jms.server.recovery.RecoveryDiscovery

All Implemented Interfaces:

SessionFailureListener, FailureListener

public class RecoveryDiscovery
extends Object
implements SessionFailureListener

This class will have a simple Connection Factory and will listen for topology updates.

This Discovery is instantiated by HornetQRecoveryRegistry

Author:

clebertsuconic

Constructor Summary

Constructors

Constructor and Description
RecoveryDiscovery(XARecoveryConfig config)

Method Summary

Methods

Modifier and Type	Method and Description
void	beforeReconnect(HornetQException exception) Notifies that a connection has failed due to the specified exception.
void	connectionFailed(HornetQException exception, boolean failedOver) Notifies that a connection has failed due to the specified exception.
int	decrementUsage()
protected void	finalize()
int	incrementUsage() we may have several connection factories referencing the same connection recovery entry.
protected void	internalStop()
void	start()
void	stop()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

RecoveryDiscovery

public RecoveryDiscovery(XARecoveryConfig config)

Method Detail

start

public void start()

stop

public void stop()

incrementUsage

public int incrementUsage()

we may have several connection factories referencing the same connection recovery entry. Because of that we need to make a count of the number of the instances that are referencing it, so we will remove it as soon as we are done

decrementUsage

public int decrementUsage()

finalize

protected void finalize()

Overrides:

finalize in class Object

internalStop

protected void internalStop()

connectionFailed

public void connectionFailed(HornetQException exception,
                    boolean failedOver)

Description copied from interface: FailureListener

Notifies that a connection has failed due to the specified exception.

Specified by:

connectionFailed in interface FailureListener

Parameters:

exception - exception which has caused the connection to fail

beforeReconnect

public void beforeReconnect(HornetQException exception)

Description copied from interface: SessionFailureListener

Notifies that a connection has failed due to the specified exception.
This method is called before the session attempts to reconnect/failover.

Specified by:

beforeReconnect in interface SessionFailureListener

Parameters:

exception - exception which has caused the connection to fail

toString

public String toString()

Overrides:

toString in class Object