org.teiid.dqp.internal.process
Class TransactionServerImpl

java.lang.Object
  org.teiid.dqp.internal.process.TransactionServerImpl

All Implemented Interfaces:

TransactionService

public class TransactionServerImpl
extends java.lang.Object
implements TransactionService

Constructor Summary

TransactionServerImpl()

Method Summary

TransactionContext	begin(java.lang.String threadId) Local Transaction
TransactionContext	begin(TransactionContext context) Request level transaction
void	cancelTransactions(java.lang.String threadId, boolean requestOnly)
void	commit(java.lang.String threadId) Local Transaction
void	commit(java.lang.String threadId, XidImpl xid, boolean onePhase, boolean singleTM) Global Transaction
TransactionContext	commit(TransactionContext context) Request level transaction
void	end(java.lang.String threadId, XidImpl xid, int flags, boolean singleTM) Global Transaction
void	forget(java.lang.String threadId, XidImpl xid, boolean singleTM) Global Transaction
TransactionContext	getOrCreateTransactionContext(java.lang.String threadId)
java.util.Collection<Transaction>	getTransactions()
int	prepare(java.lang.String threadId, XidImpl xid, boolean singleTM) Global Transaction
javax.transaction.xa.Xid[]	recover(int flag, boolean singleTM) Global Transaction
void	resume(TransactionContext context)
void	rollback(java.lang.String threadId) Local Transaction
void	rollback(java.lang.String threadId, XidImpl xid, boolean singleTM) Global Transaction
TransactionContext	rollback(TransactionContext context) Request level transaction
void	setTransactionManager(javax.transaction.TransactionManager transactionManager)
void	setWorkManager(javax.resource.spi.work.WorkManager workManager)
void	setXaTerminator(javax.resource.spi.XATerminator xaTerminator)
void	start(java.lang.String threadId, XidImpl xid, int flags, int timeout, boolean singleTM) Global Transaction
void	suspend(TransactionContext context)
void	terminateTransaction(java.lang.String threadId)

Methods inherited from class java.lang.Object

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

Constructor Detail

TransactionServerImpl

public TransactionServerImpl()

Method Detail

setXaTerminator

public void setXaTerminator(javax.resource.spi.XATerminator xaTerminator)

setTransactionManager

public void setTransactionManager(javax.transaction.TransactionManager transactionManager)

setWorkManager

public void setWorkManager(javax.resource.spi.work.WorkManager workManager)

prepare

public int prepare(java.lang.String threadId,
                   XidImpl xid,
                   boolean singleTM)
            throws XATransactionException

Global Transaction

Specified by:

prepare in interface TransactionService

Throws:

XATransactionException

commit

public void commit(java.lang.String threadId,
                   XidImpl xid,
                   boolean onePhase,
                   boolean singleTM)
            throws XATransactionException

Global Transaction

Specified by:

commit in interface TransactionService

Throws:

XATransactionException

rollback

public void rollback(java.lang.String threadId,
                     XidImpl xid,
                     boolean singleTM)
              throws XATransactionException

Global Transaction

Specified by:

rollback in interface TransactionService

Throws:

XATransactionException

recover

public javax.transaction.xa.Xid[] recover(int flag,
                                          boolean singleTM)
                                   throws XATransactionException

Global Transaction

Specified by:

recover in interface TransactionService

Throws:

XATransactionException

forget

public void forget(java.lang.String threadId,
                   XidImpl xid,
                   boolean singleTM)
            throws XATransactionException

Global Transaction

Specified by:

forget in interface TransactionService

Throws:

XATransactionException

start

public void start(java.lang.String threadId,
                  XidImpl xid,
                  int flags,
                  int timeout,
                  boolean singleTM)
           throws XATransactionException

Global Transaction

Specified by:

start in interface TransactionService

Throws:

XATransactionException

end

public void end(java.lang.String threadId,
                XidImpl xid,
                int flags,
                boolean singleTM)
         throws XATransactionException

Global Transaction

Specified by:

end in interface TransactionService

Throws:

XATransactionException

suspend

public void suspend(TransactionContext context)
             throws XATransactionException

Specified by:

suspend in interface TransactionService

Throws:

XATransactionException

resume

public void resume(TransactionContext context)
            throws XATransactionException

Specified by:

resume in interface TransactionService

Throws:

XATransactionException

begin

public TransactionContext begin(java.lang.String threadId)
                         throws XATransactionException

Local Transaction

Specified by:

begin in interface TransactionService

Throws:

XATransactionException

commit

public void commit(java.lang.String threadId)
            throws XATransactionException

Local Transaction

Specified by:

commit in interface TransactionService

Throws:

XATransactionException

rollback

public void rollback(java.lang.String threadId)
              throws XATransactionException

Local Transaction

Specified by:

rollback in interface TransactionService

Throws:

XATransactionException

getOrCreateTransactionContext

public TransactionContext getOrCreateTransactionContext(java.lang.String threadId)

Specified by:

getOrCreateTransactionContext in interface TransactionService

begin

public TransactionContext begin(TransactionContext context)
                         throws XATransactionException

Request level transaction

Specified by:

begin in interface TransactionService

Throws:

XATransactionException

commit

public TransactionContext commit(TransactionContext context)
                          throws XATransactionException

Request level transaction

Specified by:

commit in interface TransactionService

Throws:

XATransactionException

rollback

public TransactionContext rollback(TransactionContext context)
                            throws XATransactionException

Request level transaction

Specified by:

rollback in interface TransactionService

Throws:

XATransactionException

cancelTransactions

public void cancelTransactions(java.lang.String threadId,
                               boolean requestOnly)
                        throws XATransactionException

Specified by:

cancelTransactions in interface TransactionService

Throws:

XATransactionException

getTransactions

public java.util.Collection<Transaction> getTransactions()

Specified by:

getTransactions in interface TransactionService

terminateTransaction

public void terminateTransaction(java.lang.String threadId)
                          throws AdminException

Specified by:

terminateTransaction in interface TransactionService

Throws:

AdminException