org.jboss.narayana.jta.jms

Class JmsXAResourceRecoveryHelper

java.lang.Object

org.jboss.narayana.jta.jms.JmsXAResourceRecoveryHelper

All Implemented Interfaces:

XAResourceRecoveryHelper, XAResource

public class JmsXAResourceRecoveryHelper
extends Object
implements XAResourceRecoveryHelper, XAResource

Author:

Gytis Trikleris

Field Summary

Fields inherited from interface javax.transaction.xa.XAResource

TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY

Constructor Summary

Constructors

Constructor and Description
JmsXAResourceRecoveryHelper(javax.jms.XAConnectionFactory xaConnectionFactory)
JmsXAResourceRecoveryHelper(javax.jms.XAConnectionFactory xaConnectionFactory, String user, String pass)

Method Summary

Modifier and Type	Method and Description
void	commit(Xid xid, boolean b) Delegates XAResource#commit call to the connected JMS resource.
void	end(Xid xid, int i) Delegates XAResource#end call to the connected JMS resource.
void	forget(Xid xid) Delegates XAResource#forget call to the connected JMS resource.
int	getTransactionTimeout() Delegates XAResource#getTransactionTimeout call to the connected JMS resource.
XAResource[]	getXAResources() If JMS connection was created successfully, returns an array with one instance of JmsXAResourceRecoveryHelper.
boolean	initialise(String properties) Nothing to initialise.
boolean	isSameRM(XAResource xaResource) Delegates XAResource#isSameRM call to the connected JMS resource.
int	prepare(Xid xid) Delegates XAResource#prepare call to the connected JMS resource.
Xid[]	recover(int i) Delegates XAResource#recover call to the connected JMS resource.
void	rollback(Xid xid) Delegates XAResource#rollback call to the connected JMS resource.
boolean	setTransactionTimeout(int i) Delegates XAResource#setTransactionTimeout call to the connected JMS resource.
void	start(Xid xid, int i) Delegates XAResource#start call to the connected JMS resource.

Methods inherited from class java.lang.Object

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

Constructor Detail

JmsXAResourceRecoveryHelper

public JmsXAResourceRecoveryHelper(javax.jms.XAConnectionFactory xaConnectionFactory)

JmsXAResourceRecoveryHelper

public JmsXAResourceRecoveryHelper(javax.jms.XAConnectionFactory xaConnectionFactory,
                                   String user,
                                   String pass)

Method Detail

initialise

public boolean initialise(String properties)

Nothing to initialise.

Specified by:

initialise in interface XAResourceRecoveryHelper

Parameters:

properties -

Returns:

Always returns true

getXAResources

public XAResource[] getXAResources()

If JMS connection was created successfully, returns an array with one instance of JmsXAResourceRecoveryHelper. Otherwise, returns an empty array.

Specified by:

getXAResources in interface XAResourceRecoveryHelper

Returns:

Array with one instance of JmsXAResourceRecoveryHelper or an empty array

recover

public Xid[] recover(int i)
              throws XAException

Delegates XAResource#recover call to the connected JMS resource. If provided argument is XAResource.TMENDRSCAN, then JMS connection will be closed at the end of the call.

Specified by:

recover in interface XAResource

Parameters:

i -

Throws:

XAException

start

public void start(Xid xid,
                  int i)
           throws XAException

Delegates XAResource#start call to the connected JMS resource.

Specified by:

start in interface XAResource

Parameters:

xid -

i -

Throws:

XAException

end

public void end(Xid xid,
                int i)
         throws XAException

Delegates XAResource#end call to the connected JMS resource.

Specified by:

end in interface XAResource

Parameters:

xid -

i -

Throws:

XAException

prepare

public int prepare(Xid xid)
            throws XAException

Delegates XAResource#prepare call to the connected JMS resource.

Specified by:

prepare in interface XAResource

Parameters:

xid -

Returns:

Prepare outcome

Throws:

XAException

commit

public void commit(Xid xid,
                   boolean b)
            throws XAException

Delegates XAResource#commit call to the connected JMS resource.

Specified by:

commit in interface XAResource

Parameters:

xid -

b -

Throws:

XAException

rollback

public void rollback(Xid xid)
              throws XAException

Delegates XAResource#rollback call to the connected JMS resource.

Specified by:

rollback in interface XAResource

Parameters:

xid -

Throws:

XAException

isSameRM

public boolean isSameRM(XAResource xaResource)
                 throws XAException

Delegates XAResource#isSameRM call to the connected JMS resource.

Specified by:

isSameRM in interface XAResource

Parameters:

xaResource -

Returns:

True if is same resource manager or false if not.

Throws:

XAException

forget

public void forget(Xid xid)
            throws XAException

Delegates XAResource#forget call to the connected JMS resource.

Specified by:

forget in interface XAResource

Parameters:

xid -

Throws:

XAException

getTransactionTimeout

public int getTransactionTimeout()
                          throws XAException

Delegates XAResource#getTransactionTimeout call to the connected JMS resource.

Specified by:

getTransactionTimeout in interface XAResource

Returns:

Transaction timeout value.

Throws:

XAException

setTransactionTimeout

public boolean setTransactionTimeout(int i)
                              throws XAException

Delegates XAResource#setTransactionTimeout call to the connected JMS resource.

Specified by:

setTransactionTimeout in interface XAResource

Parameters:

i -

Returns:

True if transaction timeout was set, or false if wasn't.

Throws:

XAException