org.mule.util.queue

Class QueueXaResource

java.lang.Object

org.mule.util.xa.DefaultXASession<XaQueueTypeTransactionContextAdapter>

org.mule.util.queue.QueueXaResource

All Implemented Interfaces:

XAResource

public class QueueXaResource
extends DefaultXASession<XaQueueTypeTransactionContextAdapter>

Field Summary

Fields inherited from class org.mule.util.xa.DefaultXASession

localContext, localXid, logger, resourceManager

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
QueueXaResource(AbstractXAResourceManager xaResourceManager, XaTransactionRecoverer xaTransactionRecoverer, QueueProvider queueProvider)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	commitDanglingTransaction(Xid xid, boolean onePhase) Commits a dangling transaction that can be caused by the failure of one of the XAResource involved in the transaction or a crash of the transaction manager.
protected XaQueueTypeTransactionContextAdapter	createTransactionContext(Xid xid) Creates a new transaction context with the given transaction identifier
Xid[]	recover(int i)
protected void	rollbackDandlingTransaction(Xid xid) Commits a dangling transaction that can be caused by the failure of one of the XAResource involved in the transaction or a crash of the transaction manager.

Methods inherited from class org.mule.util.xa.DefaultXASession

commit, end, forget, getResourceManager, getTransactionContext, getTransactionTimeout, getXAResource, isSameRM, prepare, rollback, setTransactionTimeout, start

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueXaResource

public QueueXaResource(AbstractXAResourceManager xaResourceManager,
               XaTransactionRecoverer xaTransactionRecoverer,
               QueueProvider queueProvider)

Method Detail

commitDanglingTransaction

protected void commitDanglingTransaction(Xid xid,
                             boolean onePhase)
                                  throws XAException

Description copied from class: DefaultXASession

Commits a dangling transaction that can be caused by the failure of one of the XAResource involved in the transaction or a crash of the transaction manager.

Specified by:

commitDanglingTransaction in class DefaultXASession<XaQueueTypeTransactionContextAdapter>

Parameters:

xid - transaction identifier

onePhase - if the commit should be done using only one phase commit

Throws:

XAException

rollbackDandlingTransaction

protected void rollbackDandlingTransaction(Xid xid)
                                    throws XAException

Description copied from class: DefaultXASession

Commits a dangling transaction that can be caused by the failure of one of the XAResource involved in the transaction or a crash of the transaction manager.

Specified by:

rollbackDandlingTransaction in class DefaultXASession<XaQueueTypeTransactionContextAdapter>

Parameters:

xid - transaction identifier

Throws:

XAException

createTransactionContext

protected XaQueueTypeTransactionContextAdapter createTransactionContext(Xid xid)

Description copied from class: DefaultXASession

Creates a new transaction context with the given transaction identifier

Specified by:

createTransactionContext in class DefaultXASession<XaQueueTypeTransactionContextAdapter>

Parameters:

xid - transaction identifier

Returns:

the new transaction context

recover

public Xid[] recover(int i)
              throws XAException

Throws:

XAException