public class WildFlyActiveMQXAResourceRecovery
extends org.apache.activemq.artemis.service.extensions.xa.recovery.ActiveMQXAResourceRecovery
implements com.arjuna.ats.jta.recovery.XAResourceRecovery
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"/>
Modifier and Type | Class and Description |
---|---|
static class |
WildFlyActiveMQXAResourceRecovery.ConfigParser |
Constructor and Description |
---|
WildFlyActiveMQXAResourceRecovery() |
Modifier and Type | Method and Description |
---|---|
protected void |
finalize() |
XAResource |
getXAResource() |
XAResource[] |
getXAResources() |
boolean |
hasMoreResources() |
boolean |
initialise(String config) |
public boolean initialise(String config)
initialise
in interface com.arjuna.ats.jta.recovery.XAResourceRecovery
initialise
in class org.apache.activemq.artemis.service.extensions.xa.recovery.ActiveMQXAResourceRecovery
public boolean hasMoreResources()
hasMoreResources
in interface com.arjuna.ats.jta.recovery.XAResourceRecovery
hasMoreResources
in class org.apache.activemq.artemis.service.extensions.xa.recovery.ActiveMQXAResourceRecovery
public XAResource getXAResource()
getXAResource
in interface com.arjuna.ats.jta.recovery.XAResourceRecovery
getXAResource
in class org.apache.activemq.artemis.service.extensions.xa.recovery.ActiveMQXAResourceRecovery
public XAResource[] getXAResources()
getXAResources
in class org.apache.activemq.artemis.service.extensions.xa.recovery.ActiveMQXAResourceRecovery
protected void finalize()
finalize
in class org.apache.activemq.artemis.service.extensions.xa.recovery.ActiveMQXAResourceRecovery
Copyright © 2015 JBoss by Red Hat. All rights reserved.