public class HornetQXAResourceRecovery extends Object 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.HORNETQ1" value="org.hornetq.jms.server.recovery.HornetQXAResourceRecovery;org.hornetq.core.remoting.impl.invm.InVMConnectorFactory"/>
you'll need something like this if the HornetQ Server is remote
<property name="com.arjuna.ats.jta.recovery.XAResourceRecovery.HORNETQ2" value="org.hornetq.jms.server.recovery.HornetQXAResourceRecovery;org.hornetq.core.remoting.impl.netty.NettyConnectorFactory,guest,guest,host=localhost,port=5445"/>
you'll need something like this if the HornetQ Server is remote and has failover configured
<property name="com.arjuna.ats.jta.recovery.XAResourceRecovery.HORNETQ2" value="org.hornetq.jms.server.recovery.HornetQXAResourceRecovery;org.hornetq.core.remoting.impl.netty.NettyConnectorFactory,guest,guest,host=localhost,port=5445;org.hornetq.core.remoting.impl.netty.NettyConnectorFactory,guest,guest,host=localhost2,port=5446"/>
Modifier and Type | Class and Description |
---|---|
static class |
HornetQXAResourceRecovery.ConfigParser |
Constructor and Description |
---|
HornetQXAResourceRecovery() |
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
public boolean hasMoreResources()
hasMoreResources
in interface com.arjuna.ats.jta.recovery.XAResourceRecovery
public XAResource getXAResource()
getXAResource
in interface com.arjuna.ats.jta.recovery.XAResourceRecovery
public XAResource[] getXAResources()
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.