org.hornetq.jms.server.recovery
Class RecoveryDiscovery

java.lang.Object
  org.hornetq.jms.server.recovery.RecoveryDiscovery

All Implemented Interfaces:

SessionFailureListener, org.hornetq.core.remoting.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

RecoveryDiscovery(XARecoveryConfig config)

Method Summary

void	beforeReconnect(HornetQException exception)
void	connectionFailed(HornetQException exception, boolean failedOver)
int	decrementUsage()
protected void	finalize()
int	incrementUsage() we may have several connection factories referencing the same connection recovery entry.
protected void	internalStop()
void	start(boolean retry)
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(boolean retry)

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)

Specified by:

connectionFailed in interface org.hornetq.core.remoting.FailureListener

beforeReconnect

public void beforeReconnect(HornetQException exception)

Specified by:

beforeReconnect in interface SessionFailureListener

toString

public String toString()

Overrides:

toString in class Object