public class WildFlyRecoveryDiscovery extends Object implements org.apache.activemq.artemis.api.core.client.SessionFailureListener
This class will have a simple Connection Factory and will listen for topology updates.
This Discovery is instantiated by WildFlyActiveMQRecoveryRegistry
Constructor and Description |
---|
WildFlyRecoveryDiscovery(org.apache.activemq.artemis.service.extensions.xa.recovery.XARecoveryConfig config) |
Modifier and Type | Method and Description |
---|---|
void |
beforeReconnect(org.apache.activemq.artemis.api.core.ActiveMQException exception) |
void |
connectionFailed(org.apache.activemq.artemis.api.core.ActiveMQException exception,
boolean failedOver) |
void |
connectionFailed(org.apache.activemq.artemis.api.core.ActiveMQException me,
boolean failedOver,
String scaleDownTargetNodeID) |
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 WildFlyRecoveryDiscovery(org.apache.activemq.artemis.service.extensions.xa.recovery.XARecoveryConfig config)
public void start(boolean retry)
public void stop()
public int incrementUsage()
public int decrementUsage()
protected void internalStop()
public void connectionFailed(org.apache.activemq.artemis.api.core.ActiveMQException exception, boolean failedOver)
connectionFailed
in interface org.apache.activemq.artemis.core.remoting.FailureListener
public void connectionFailed(org.apache.activemq.artemis.api.core.ActiveMQException me, boolean failedOver, String scaleDownTargetNodeID)
connectionFailed
in interface org.apache.activemq.artemis.core.remoting.FailureListener
public void beforeReconnect(org.apache.activemq.artemis.api.core.ActiveMQException exception)
beforeReconnect
in interface org.apache.activemq.artemis.api.core.client.SessionFailureListener
Copyright © 2018 JBoss by Red Hat. All rights reserved.