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 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 -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected voidfinalize()booleanbooleaninitialise(String config)
-
Constructor Details
-
WildFlyActiveMQXAResourceRecovery
public WildFlyActiveMQXAResourceRecovery()
-
-
Method Details
-
initialise
- Specified by:
initialisein interfacecom.arjuna.ats.jta.recovery.XAResourceRecovery- Overrides:
initialisein classActiveMQXAResourceRecovery
-
hasMoreResources
public boolean hasMoreResources()- Specified by:
hasMoreResourcesin interfacecom.arjuna.ats.jta.recovery.XAResourceRecovery- Overrides:
hasMoreResourcesin classActiveMQXAResourceRecovery
-
getXAResource
- Specified by:
getXAResourcein interfacecom.arjuna.ats.jta.recovery.XAResourceRecovery- Overrides:
getXAResourcein classActiveMQXAResourceRecovery
-
getXAResources
- Overrides:
getXAResourcesin classActiveMQXAResourceRecovery
-
finalize
protected void finalize()
-