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
Constructor and Description |
---|
RecoveryDiscovery(XARecoveryConfig config) |
Modifier and Type | Method and Description |
---|---|
void |
beforeReconnect(HornetQException exception) |
void |
connectionFailed(HornetQException exception,
boolean failedOver) |
int |
decrementUsage() |
boolean |
equals(Object o) |
protected void |
finalize() |
int |
hashCode() |
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() |
public RecoveryDiscovery(XARecoveryConfig config)
public void start(boolean retry)
public void stop()
public int incrementUsage()
public int decrementUsage()
protected void internalStop()
public void connectionFailed(HornetQException exception, boolean failedOver)
connectionFailed
in interface org.hornetq.core.remoting.FailureListener
public void beforeReconnect(HornetQException exception)
beforeReconnect
in interface SessionFailureListener
Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.