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

Class WildFlyActiveMQXAResourceRecovery

java.lang.Object

org.apache.activemq.artemis.service.extensions.xa.recovery.ActiveMQXAResourceRecovery

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

All Implemented Interfaces:

com.arjuna.ats.jta.recovery.XAResourceRecovery

public class WildFlyActiveMQXAResourceRecovery
extends org.apache.activemq.artemis.service.extensions.xa.recovery.ActiveMQXAResourceRecovery
implements com.arjuna.ats.jta.recovery.XAResourceRecovery

A XAResourceRecovery instance that can be used to recover any JMS provider.

In reality only recover, rollback and commit will be called but we still need to be implement all methods just in case.

To enable this add the following to the jbossts-properties file

 <property name="com.arjuna.ats.jta.recovery.XAResourceRecovery.ACTIVEMQ1"
                 value="org.apache.activemq.jms.server.recovery.ActiveMQXAResourceRecovery;org.apache.activemq.core.remoting.impl.invm.InVMConnectorFactory"/>
 

you'll need something like this if the ActiveMQ Server is remote

      <property name="com.arjuna.ats.jta.recovery.XAResourceRecovery.ACTIVEMQ2"
                  value="org.apache.activemq.jms.server.recovery.ActiveMQXAResourceRecovery;org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory,guest,guest,host=localhost,port=5445"/>
 

you'll need something like this if the ActiveMQ Server is remote and has failover configured

             <property name="com.arjuna.ats.jta.recovery.XAResourceRecovery.ACTIVEMQ2"
                       value="org.apache.activemq.jms.server.recovery.ActiveMQXAResourceRecovery;org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory,guest,guest,host=localhost,port=5445;org.apache.activemq.core.remoting.impl.netty.NettyConnectorFactory,guest,guest,host=localhost2,port=5446"/>
 

Version:

$Revision: 1.1 $

Author:

Tim Fox, Andy Taylor

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	WildFlyActiveMQXAResourceRecovery.ConfigParser

Constructor Summary

Constructors

Constructor and Description
WildFlyActiveMQXAResourceRecovery()

Method Summary

Modifier and Type	Method and Description
protected void	finalize()
XAResource	getXAResource()
XAResource[]	getXAResources()
boolean	hasMoreResources()
boolean	initialise(String config)

Methods inherited from class java.lang.Object

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

Constructor Detail

WildFlyActiveMQXAResourceRecovery

public WildFlyActiveMQXAResourceRecovery()

Method Detail

initialise

public boolean initialise(String config)

Specified by:

initialise in interface com.arjuna.ats.jta.recovery.XAResourceRecovery

Overrides:

initialise in class org.apache.activemq.artemis.service.extensions.xa.recovery.ActiveMQXAResourceRecovery

hasMoreResources

public boolean hasMoreResources()

Specified by:

hasMoreResources in interface com.arjuna.ats.jta.recovery.XAResourceRecovery

Overrides:

hasMoreResources in class org.apache.activemq.artemis.service.extensions.xa.recovery.ActiveMQXAResourceRecovery

getXAResource

public XAResource getXAResource()

Specified by:

getXAResource in interface com.arjuna.ats.jta.recovery.XAResourceRecovery

Overrides:

getXAResource in class org.apache.activemq.artemis.service.extensions.xa.recovery.ActiveMQXAResourceRecovery

getXAResources

public XAResource[] getXAResources()

Overrides:

getXAResources in class org.apache.activemq.artemis.service.extensions.xa.recovery.ActiveMQXAResourceRecovery

finalize

protected void finalize()

Overrides:

finalize in class org.apache.activemq.artemis.service.extensions.xa.recovery.ActiveMQXAResourceRecovery