org.hornetq.jms.server.recovery
public class HornetQRecoveryRegistry extends Object implements org.jboss.tm.XAResourceRecovery
This class is used by the Resource Adapter to register RecoveryDiscovery, which is based on the XARecoveryConfig
Each outbound or inboud connection will pass the configuration here through by calling the method register(XARecoveryConfig)
Later the RecoveryDiscovery
will call nodeUp(String, Pair, String, String)
so we will keep a track of nodes on the cluster
or nodes where this server is connected to.
Modifier and Type | Method and Description |
---|---|
void |
failedDiscovery(RecoveryDiscovery failedDiscovery)
in case of a failure the Discovery will register itslef to retry
|
static HornetQRecoveryRegistry |
getInstance() |
XAResource[] |
getXAResources()
This will be called periodically by the Transaction Manager
|
void |
nodeDown(String nodeID) |
void |
nodeUp(String nodeID,
Pair<TransportConfiguration,TransportConfiguration> networkConfiguration,
String username,
String password) |
void |
register(XARecoveryConfig resourceConfig)
This will be called by then resource adapters, to register a new discovery
|
void |
stop()
We need to make sure that all resources are closed, we don't actually do this when a resourceConfig is closed but
maybe we should.
|
void |
unRegister(XARecoveryConfig resourceConfig)
Reference counts and deactivate a configuration
Notice: this won't remove the servers since a server may have previous XIDs
|
public XAResource[] getXAResources()
getXAResources
in interface org.jboss.tm.XAResourceRecovery
public static HornetQRecoveryRegistry getInstance()
public void register(XARecoveryConfig resourceConfig)
resourceConfig
- public void unRegister(XARecoveryConfig resourceConfig)
resourceConfig
- public void stop()
public void failedDiscovery(RecoveryDiscovery failedDiscovery)
failedDiscovery
- public void nodeUp(String nodeID, Pair<TransportConfiguration,TransportConfiguration> networkConfiguration, String username, String password)
nodeID
- pair
- username
- password
- public void nodeDown(String nodeID)
Copyright © 2015 JBoss, a division of Red Hat. All Rights Reserved.