com.atomikos.icatch.imp

Class CompositeTransactionManagerImp

java.lang.Object

com.atomikos.icatch.imp.CompositeTransactionManagerImp

All Implemented Interfaces:

CompositeTransactionManager, SubTxAwareParticipant

public class CompositeTransactionManagerImp
extends java.lang.Object
implements CompositeTransactionManager, SubTxAwareParticipant

Reusable (generic) composite transaction manager implementation.

Constructor Summary

Constructors

Constructor and Description
CompositeTransactionManagerImp()

Method Summary

Modifier and Type	Method and Description
void	committed(CompositeTransaction tx) Called if a tx is ended successfully.
CompositeTransaction	createCompositeTransaction(long timeout)
CompositeTransaction	getCompositeTransaction()
CompositeTransaction	getCompositeTransaction(java.lang.String tid)
CompositeTransaction	recreateCompositeTransaction(Propagation context) Recreate a composite transaction based on an imported context.
void	resume(CompositeTransaction ct)
void	rolledback(CompositeTransaction tx) Called if a tx is ended with failure.
void	shutdown(boolean force) Shut down the server in a clean way.
protected void	startlistening(CompositeTransaction transaction)
CompositeTransaction	suspend()

Methods inherited from class java.lang.Object

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

Constructor Detail

CompositeTransactionManagerImp

public CompositeTransactionManagerImp()

Method Detail

committed

public void committed(CompositeTransaction tx)

Called if a tx is ended successfully. In order to remove the tx from the mapping.

Specified by:

committed in interface SubTxAwareParticipant

See Also:

SubTxAwareParticipant

rolledback

public void rolledback(CompositeTransaction tx)

Called if a tx is ended with failure. In order to remove tx from mapping.

Specified by:

rolledback in interface SubTxAwareParticipant

See Also:

SubTxAwareParticipant

getCompositeTransaction

public CompositeTransaction getCompositeTransaction()
                                             throws SysException

Specified by:

getCompositeTransaction in interface CompositeTransactionManager

Throws:

SysException

See Also:

CompositeTransactionManager

getCompositeTransaction

public CompositeTransaction getCompositeTransaction(java.lang.String tid)
                                             throws SysException

Specified by:

getCompositeTransaction in interface CompositeTransactionManager

Throws:

SysException

See Also:

CompositeTransactionManager

recreateCompositeTransaction

public CompositeTransaction recreateCompositeTransaction(Propagation context)
                                                  throws SysException

Recreate a composite transaction based on an imported context. Needed by the application's communication layer.

Specified by:

recreateCompositeTransaction in interface CompositeTransactionManager

Parameters:

context - The propagationcontext.

Returns:

CompositeTransaction The recreated local instance.

Throws:

SysException - Failure.

suspend

public CompositeTransaction suspend()
                             throws SysException

Specified by:

suspend in interface CompositeTransactionManager

Throws:

SysException

See Also:

CompositeTransactionManager

resume

public void resume(CompositeTransaction ct)
            throws java.lang.IllegalStateException,
                   SysException

Specified by:

resume in interface CompositeTransactionManager

Throws:

java.lang.IllegalStateException

SysException

See Also:

CompositeTransactionManager

shutdown

public void shutdown(boolean force)
              throws SysException,
                     java.lang.IllegalStateException

Shut down the server in a clean way.

Parameters:

force - If true, shutdown will not wait for possibly indoubt txs to finish. Calling shutdown with force being true implies that shutdown will not fail, but there may be remaining timer threads that stay asleep until there timeouts expire. Such remaining active transactions will NOT be able to finish, because the recovery manager will be shutdown by that time. New transactions will not be allowed.

Throws:

SysException - For unexpected errors.

java.lang.IllegalStateException - If active txs exist, and not force.

startlistening

protected void startlistening(CompositeTransaction transaction)
                       throws SysException

Throws:

SysException

createCompositeTransaction

public CompositeTransaction createCompositeTransaction(long timeout)
                                                throws SysException

Specified by:

createCompositeTransaction in interface CompositeTransactionManager

Throws:

SysException

See Also:

CompositeTransactionManager