Class Join

java.lang.Object

org.jpos.transaction.participant.Join

All Implemented Interfaces:

XmlConfigurable, AbortParticipant, TransactionConstants, TransactionParticipant

public class Join
extends Object
implements TransactionConstants, AbortParticipant, XmlConfigurable

Transaction participant that runs a list of nested participants concurrently (one virtual thread each) and merges their lifecycle results.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Join.Runner	Wraps a single nested TransactionParticipant in its own virtual thread so its lifecycle calls can run concurrently with siblings.

Field Summary

Fields inherited from interface TransactionConstants

ABORTED, FAIL, NO_JOIN, PAUSE, PREPARED, READONLY, RETRY

Modifier and Type	Field	Description
static final int	ABORTED	Transaction has been aborted.
static final int	FAIL	Shortcut for a read-only, non-joining abort (READONLY | NO_JOIN).
static final int	NO_JOIN	This participant does not join the transaction
static final int	PAUSE	Transaction is paused.
static final int	PREPARED	Transaction has been prepared successfully.
static final int	READONLY	Context has not been modified (no need to persist a snapshot)
static final int	RETRY	Transaction should be retried.

Constructor Summary

Constructors

Constructor	Description
Join()	Default constructor; no instance state to initialise.

Method Summary

Modifier and Type	Method	Description
void	abort(long id, Serializable o)	Runs abort on every nested participant in parallel.
void	commit(long id, Serializable o)	Runs commit on every nested participant in parallel.
int	prepare(long id, Serializable o)	Runs prepare on every nested participant in parallel and merges their results.
int	prepareForAbort(long id, Serializable o)	Runs prepareForAbort on every nested participant in parallel and merges their results.
void	setConfiguration(org.jdom2.Element e)	Reads <participant> children from e and instantiates each via the associated TransactionManager.
void	setTransactionManager(TransactionManager mgr)	Captures the TransactionManager used to construct nested participants.

Methods inherited from class Object

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

Constructor Details

Join

public Join()

Default constructor; no instance state to initialise.

Method Details

prepare

public int prepare(long id,
 Serializable o)

Runs prepare on every nested participant in parallel and merges their results.

Specified by:

prepare in interface TransactionParticipant

Parameters:

id - transaction id

o - transaction context

Returns:

the merged action mask

prepareForAbort

public int prepareForAbort(long id,
 Serializable o)

Runs prepareForAbort on every nested participant in parallel and merges their results.

Specified by:

prepareForAbort in interface AbortParticipant

Parameters:

id - transaction id

o - transaction context

Returns:

the merged action mask

commit

public void commit(long id,
 Serializable o)

Runs commit on every nested participant in parallel.

Specified by:

commit in interface TransactionParticipant

Parameters:

id - transaction id

o - transaction context

abort

public void abort(long id,
 Serializable o)

Runs abort on every nested participant in parallel.

Specified by:

abort in interface TransactionParticipant

Parameters:

id - transaction id

o - transaction context

setConfiguration

public void setConfiguration(org.jdom2.Element e)
                      throws ConfigurationException

Reads <participant> children from e and instantiates each via the associated TransactionManager.

Specified by:

setConfiguration in interface XmlConfigurable

Parameters:

e - XML configuration element

Throws:

ConfigurationException - if any nested participant fails to instantiate

setTransactionManager

public void setTransactionManager(TransactionManager mgr)

Captures the TransactionManager used to construct nested participants.

Parameters:

mgr - the hosting transaction manager