org.jboss.activemq.artemis.wildfly.integration.recovery

Class WildFlyActiveMQRecoveryRegistry

java.lang.Object

org.jboss.activemq.artemis.wildfly.integration.recovery.WildFlyActiveMQRecoveryRegistry

All Implemented Interfaces:

org.jboss.tm.XAResourceRecovery

public class WildFlyActiveMQRecoveryRegistry
extends Object
implements org.jboss.tm.XAResourceRecovery

This class is used by the Resource Adapter to register RecoveryDiscovery, which is based on the org.apache.activemq.wildfly.integration.recovery.XARecoveryConfig

Each outbound or inboud connection will pass the configuration here through by calling the method WildFlyActiveMQRecoveryRegistry#register(org.apache.activemq.wildfly.integration.recovery.XARecoveryConfig)

Later the WildFlyRecoveryDiscovery will call WildFlyActiveMQRecoveryRegistry#nodeUp(String, org.apache.activemq.api.core.Pair, String, String) so we will keep a track of nodes on the cluster or nodes where this server is connected to.

Author:

clebertsuconic

Method Summary

Modifier and Type	Method and Description
void	failedDiscovery(WildFlyRecoveryDiscovery failedDiscovery) in case of a failure the Discovery will register itslef to retry
static WildFlyActiveMQRecoveryRegistry	getInstance()
XAResource[]	getXAResources() This will be called periodically by the Transaction Manager
void	nodeDown(String nodeID)
void	nodeUp(org.apache.activemq.artemis.service.extensions.xa.recovery.XARecoveryConfig listeningConfig, String nodeID, org.apache.activemq.artemis.api.core.Pair<org.apache.activemq.artemis.api.core.TransportConfiguration,org.apache.activemq.artemis.api.core.TransportConfiguration> networkConfiguration, String username, String password, Map<String,String> properties)
void	register(org.apache.activemq.artemis.service.extensions.xa.recovery.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(org.apache.activemq.artemis.service.extensions.xa.recovery.XARecoveryConfig resourceConfig) Reference counts and deactivate a configuration Notice: this won't remove the servers since a server may have previous XIDs

Methods inherited from class java.lang.Object

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

Method Detail

getXAResources

public XAResource[] getXAResources()

This will be called periodically by the Transaction Manager

Specified by:

getXAResources in interface org.jboss.tm.XAResourceRecovery

getInstance

public static WildFlyActiveMQRecoveryRegistry getInstance()

register

public void register(org.apache.activemq.artemis.service.extensions.xa.recovery.XARecoveryConfig resourceConfig)

This will be called by then resource adapters, to register a new discovery

Parameters:

resourceConfig -

unRegister

public void unRegister(org.apache.activemq.artemis.service.extensions.xa.recovery.XARecoveryConfig resourceConfig)

Reference counts and deactivate a configuration Notice: this won't remove the servers since a server may have previous XIDs

Parameters:

resourceConfig -

stop

public 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.

failedDiscovery

public void failedDiscovery(WildFlyRecoveryDiscovery failedDiscovery)

in case of a failure the Discovery will register itslef to retry

Parameters:

failedDiscovery -

nodeUp

public void nodeUp(org.apache.activemq.artemis.service.extensions.xa.recovery.XARecoveryConfig listeningConfig,
                   String nodeID,
                   org.apache.activemq.artemis.api.core.Pair<org.apache.activemq.artemis.api.core.TransportConfiguration,org.apache.activemq.artemis.api.core.TransportConfiguration> networkConfiguration,
                   String username,
                   String password,
                   Map<String,String> properties)

Parameters:

listeningConfig - the connection factory where we are listening topology updates.

nodeID - the node id coming from the topology update

networkConfiguration - the network configuration

username - the user name

password - the password

properties - the properties passed to the configuration

nodeDown

public void nodeDown(String nodeID)