org.jpos.transaction
Class TransactionManager

java.lang.Object
  org.jpos.q2.QBeanSupport
      org.jpos.transaction.TransactionManager

All Implemented Interfaces:

java.lang.Runnable, Configurable, QBean, QBeanSupportMBean, QPersist, TransactionConstants, TransactionManagerMBean

public class TransactionManager
extends QBeanSupport
implements java.lang.Runnable, TransactionConstants, TransactionManagerMBean

Nested Class Summary

class	TransactionManager.PausedMonitor
class	TransactionManager.RetryTask

Field Summary

static java.lang.Integer	COMMITTING
static java.lang.String	CONTEXT
static java.lang.String	DEFAULT_GROUP
static java.lang.Integer	DONE
static java.lang.String	GROUPS
static java.lang.String	HEAD
static java.lang.String	LAST_RETRY
static long	MAX_PARTICIPANTS
static java.lang.Integer	PREPARING
static java.lang.String	RETRY_QUEUE
static java.lang.String	STATE
static java.lang.String	TAIL
static java.lang.String	TAILLOCK

Fields inherited from class org.jpos.q2.QBeanSupport

stateString

Fields inherited from interface org.jpos.transaction.TransactionConstants

ABORTED, NO_JOIN, PAUSE, PREPARED, READONLY, RETRY

Fields inherited from interface org.jpos.q2.QBean

DESTROYED, FAILED, STARTED, STARTING, STOPPED, STOPPING

Constructor Summary

TransactionManager()

Method Summary

TransactionParticipant	createParticipant(org.jdom.Element e)
int	getActiveSessions()
boolean	getDebug()
long	getHead()
int	getOutstandingTransactions()
Space	getPersistentSpace()
java.lang.String	getQueueName()
Space	getSpace()
long	getTail()
void	initService()
void	push(java.io.Serializable context)
void	queue(java.io.Serializable context)
void	run()
void	setConfiguration(Configuration cfg)
void	setDebug(boolean debug)
void	startService()
void	stopService()

Methods inherited from class org.jpos.q2.QBeanSupport

destroy, getConfiguration, getFactory, getLoader, getLoaderURLS, getLog, getLogger, getName, getPersist, getRealm, getServer, getState, getStateAsString, init, isModified, running, setLogger, setModified, setName, setPersist, setRealm, setServer, setState, shutdownQ2, start, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jpos.q2.QBeanSupportMBean

getLoader, getLoaderURLS, getLogger, getName, getRealm, getServer, setLogger, setName, setPersist, setRealm, setServer, shutdownQ2

Methods inherited from interface org.jpos.q2.QBean

destroy, getState, getStateAsString, init, start, stop

Methods inherited from interface org.jpos.q2.QPersist

getPersist, isModified

Field Detail

HEAD

public static final java.lang.String HEAD

See Also:

Constant Field Values

TAIL

public static final java.lang.String TAIL

See Also:

Constant Field Values

CONTEXT

public static final java.lang.String CONTEXT

See Also:

Constant Field Values

STATE

public static final java.lang.String STATE

See Also:

Constant Field Values

GROUPS

public static final java.lang.String GROUPS

See Also:

Constant Field Values

TAILLOCK

public static final java.lang.String TAILLOCK

See Also:

Constant Field Values

RETRY_QUEUE

public static final java.lang.String RETRY_QUEUE

See Also:

Constant Field Values

LAST_RETRY

public static final java.lang.String LAST_RETRY

See Also:

Constant Field Values

PREPARING

public static final java.lang.Integer PREPARING

COMMITTING

public static final java.lang.Integer COMMITTING

DONE

public static final java.lang.Integer DONE

DEFAULT_GROUP

public static final java.lang.String DEFAULT_GROUP

See Also:

Constant Field Values

MAX_PARTICIPANTS

public static final long MAX_PARTICIPANTS

See Also:

Constant Field Values

Constructor Detail

TransactionManager

public TransactionManager()

Method Detail

initService

public void initService()
                 throws ConfigurationException

Throws:

ConfigurationException

startService

public void startService()
                  throws java.lang.Exception

Throws:

java.lang.Exception

stopService

public void stopService()
                 throws java.lang.Exception

Throws:

java.lang.Exception

queue

public void queue(java.io.Serializable context)

push

public void push(java.io.Serializable context)

getQueueName

public java.lang.String getQueueName()

getSpace

public Space getSpace()

getPersistentSpace

public Space getPersistentSpace()

run

public void run()

Specified by:

run in interface java.lang.Runnable

getTail

public long getTail()

Specified by:

getTail in interface TransactionManagerMBean

getHead

public long getHead()

Specified by:

getHead in interface TransactionManagerMBean

setConfiguration

public void setConfiguration(Configuration cfg)
                      throws ConfigurationException

Specified by:

setConfiguration in interface Configurable

Overrides:

setConfiguration in class QBeanSupport

Parameters:

cfg - Configuration object

Throws:

ConfigurationException

createParticipant

public TransactionParticipant createParticipant(org.jdom.Element e)
                                         throws ConfigurationException

Throws:

ConfigurationException

getOutstandingTransactions

public int getOutstandingTransactions()

Specified by:

getOutstandingTransactions in interface TransactionManagerMBean

setDebug

public void setDebug(boolean debug)

Specified by:

setDebug in interface TransactionManagerMBean

getDebug

public boolean getDebug()

Specified by:

getDebug in interface TransactionManagerMBean

getActiveSessions

public int getActiveSessions()

Specified by:

getActiveSessions in interface TransactionManagerMBean