Class TransactionManager

java.lang.Object

org.jpos.q2.QBeanSupport

org.jpos.transaction.TransactionManager

All Implemented Interfaces:

Runnable, Configurable, QBean, QBeanSupportMBean, QPersist, TransactionConstants, TransactionManagerMBean, Loggeable, MetricsProvider

public class TransactionManager
extends QBeanSupport
implements Runnable, TransactionConstants, TransactionManagerMBean, Loggeable, MetricsProvider

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	TransactionManager.InputQueueMonitor
class	TransactionManager.RetryTask
static final record	TransactionManager.Trace

Field Summary

Fields

Modifier and Type	Field	Description
static final Integer	COMMITTING
static final String	CONTEXT
static final String	DEFAULT_GROUP
static final Integer	DONE
protected Map<String, List<TransactionParticipant>>	groups
static final String	GROUPS
static final long	MAX_PARTICIPANTS
static final long	MAX_WAIT
static final Integer	PREPARING
static final String	RETRY_QUEUE
static final String	STATE

Fields inherited from class QBeanSupport

cfg, log, scheduledThreadPoolExecutor

Fields inherited from interface QBean

DESTROYED, FAILED, STARTED, STARTING, stateString, STOPPED, STOPPING

Fields inherited from interface TransactionConstants

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

Constructor Summary

Constructors

Constructor	Description
TransactionManager()

Method Summary

Modifier and Type	Method	Description
protected void	abort(int session, long id, Serializable context, List<TransactionParticipant> members, boolean recover, LogEvent evt, Profiler prof)
protected void	abort(TransactionParticipant p, long id, Serializable context)
protected void	addGroup(long id, String groupName)
void	addListener(TransactionStatusListener l)
protected void	checkRetryTask()
protected void	checkTail()
protected void	commit(int session, long id, Serializable context, List<TransactionParticipant> members, boolean recover, LogEvent evt, Profiler prof)
protected void	commit(TransactionParticipant p, long id, Serializable context)
protected void	commitOff(Space sp)
protected void	commitOn(Space sp)
TransactionParticipant	createParticipant(org.jdom2.Element e)
void	dump(PrintStream ps, String indent)
protected LogEvent	freeze(Serializable context, LogEvent evt, Profiler prof)	This method gives the opportunity to decorate a LogEvent right before it gets logged.
int	getActiveSessions()
static <T extends Serializable> T	getContext()
long	getHead()
static Long	getId()
Space	getInputSpace()
long	getInTransit()
protected String	getKey(String prefix, long id)
int	getMaxSessions()
Metrics	getMetrics()
int	getOutstandingTransactions()
protected List<TransactionParticipant>	getParticipants(long id)
protected List<TransactionParticipant>	getParticipants(String groupName)
Space	getPersistentSpace()
String	getQueueName()
static Serializable	getSerializable()
protected int	getSessionsToStandUp()	This method returns the number of sessions that can be started at this point in time
Space	getSpace()
long	getTail()
TPS	getTPS()
String	getTPSAsString()
float	getTPSAvg()
long	getTPSElapsed()
int	getTPSPeak()
Date	getTPSPeakWhen()
protected List<TransactionParticipant>	initGroup(org.jdom2.Element e)
protected void	initParticipants(org.jdom2.Element config)
void	initService()
protected void	initStatusListeners(org.jdom2.Element config)
protected boolean	isSessionToStandDown()	This method returns true if current session should stop working on more messages
protected int	prepare(int session, long id, Serializable context, List<TransactionParticipant> members, Iterator<TransactionParticipant> iter, boolean abort, LogEvent evt, Profiler prof, Chronometer chronometer)
protected int	prepare(TransactionParticipant p, long id, Serializable context)
protected int	prepareForAbort(TransactionParticipant p, long id, Serializable context)
protected void	purge(long id, boolean full)
void	push(Serializable context)
void	queue(Serializable context)
protected void	recover()
protected void	recover(long id)
void	removeListener(TransactionStatusListener l)
void	resetTPS()
void	run()
void	setConfiguration(Configuration cfg)
protected void	setState(long id, Integer state)
protected void	snapshot(long id, Serializable context)
protected void	snapshot(long id, Serializable context, Integer status)
void	startService()
void	stopService()
protected boolean	tailDone()

Methods inherited from class QBeanSupport

addAttr, close, createElement, destroy, destroyService, getAttrs, getAttrs, getConfiguration, getDump, getFactory, getLoader, getLoaderURLS, getLog, getLogger, getName, getPersist, getProperties, getProperty, getRealm, getScheduledThreadPoolExecutor, getServer, getState, getStateAsString, init, isModified, running, setAttr, setLogger, setModified, setName, setPersist, setProperty, setRealm, setServer, setState, start, stop

Methods inherited from class Object

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

Methods inherited from interface Loggeable

dump

Methods inherited from interface QBean

destroy, getState, getStateAsString, init, start, stop

Methods inherited from interface QBeanSupportMBean

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

Methods inherited from interface QPersist

getPersist, isModified

Field Details

CONTEXT

public static final String CONTEXT

See Also:

• Constant Field Values

STATE

public static final String STATE

See Also:

• Constant Field Values

GROUPS

public static final String GROUPS

See Also:

• Constant Field Values

RETRY_QUEUE

public static final String RETRY_QUEUE

See Also:

• Constant Field Values

PREPARING

public static final Integer PREPARING

COMMITTING

public static final Integer COMMITTING

DONE

public static final Integer DONE

DEFAULT_GROUP

public static final String DEFAULT_GROUP

See Also:

• Constant Field Values

MAX_PARTICIPANTS

public static final long MAX_PARTICIPANTS

See Also:

• Constant Field Values

MAX_WAIT

public static final long MAX_WAIT

See Also:

• Constant Field Values

groups

protected Map<String, List<TransactionParticipant>> groups

Constructor Details

TransactionManager

public TransactionManager()

Method Details

initService

public void initService()
                 throws ConfigurationException

Overrides:

initService in class QBeanSupport

Throws:

ConfigurationException

startService

public void startService()
                  throws Exception

Overrides:

startService in class QBeanSupport

Throws:

Exception

stopService

public void stopService()

Overrides:

stopService in class QBeanSupport

queue

public void queue(Serializable context)

push

public void push(Serializable context)

getQueueName

public String getQueueName()

getSpace

public Space getSpace()

getInputSpace

public Space getInputSpace()

getPersistentSpace

public Space getPersistentSpace()

run

public void run()

Specified by:

run in interface Runnable

getTail

public long getTail()

Specified by:

getTail in interface TransactionManagerMBean

getHead

public long getHead()

Specified by:

getHead in interface TransactionManagerMBean

getInTransit

public long getInTransit()

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

addListener

public void addListener(TransactionStatusListener l)

removeListener

public void removeListener(TransactionStatusListener l)

getTPS

public TPS getTPS()

getTPSAsString

public String getTPSAsString()

Specified by:

getTPSAsString in interface TransactionManagerMBean

getTPSAvg

public float getTPSAvg()

Specified by:

getTPSAvg in interface TransactionManagerMBean

getTPSPeak

public int getTPSPeak()

Specified by:

getTPSPeak in interface TransactionManagerMBean

getTPSPeakWhen

public Date getTPSPeakWhen()

Specified by:

getTPSPeakWhen in interface TransactionManagerMBean

getTPSElapsed

public long getTPSElapsed()

Specified by:

getTPSElapsed in interface TransactionManagerMBean

resetTPS

public void resetTPS()

Specified by:

resetTPS in interface TransactionManagerMBean

getMetrics

public Metrics getMetrics()

Specified by:

getMetrics in interface MetricsProvider

dump

public void dump(PrintStream ps,
 String indent)

Specified by:

dump in interface Loggeable

commit

protected void commit(int session,
 long id,
 Serializable context,
 List<TransactionParticipant> members,
 boolean recover,
 LogEvent evt,
 Profiler prof)

abort

protected void abort(int session,
 long id,
 Serializable context,
 List<TransactionParticipant> members,
 boolean recover,
 LogEvent evt,
 Profiler prof)

prepareForAbort

protected int prepareForAbort(TransactionParticipant p,
 long id,
 Serializable context)

prepare

protected int prepare(TransactionParticipant p,
 long id,
 Serializable context)

commit

protected void commit(TransactionParticipant p,
 long id,
 Serializable context)

abort

protected void abort(TransactionParticipant p,
 long id,
 Serializable context)

prepare

protected int prepare(int session,
 long id,
 Serializable context,
 List<TransactionParticipant> members,
 Iterator<TransactionParticipant> iter,
 boolean abort,
 LogEvent evt,
 Profiler prof,
 Chronometer chronometer)

getParticipants

protected List<TransactionParticipant> getParticipants(String groupName)

getParticipants

protected List<TransactionParticipant> getParticipants(long id)

initStatusListeners

protected void initStatusListeners(org.jdom2.Element config)
                            throws ConfigurationException

Throws:

ConfigurationException

initParticipants

protected void initParticipants(org.jdom2.Element config)
                         throws ConfigurationException

Throws:

ConfigurationException

initGroup

protected List<TransactionParticipant> initGroup(org.jdom2.Element e)
                                          throws ConfigurationException

Throws:

ConfigurationException

createParticipant

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

Throws:

ConfigurationException

getOutstandingTransactions

public int getOutstandingTransactions()

Specified by:

getOutstandingTransactions in interface TransactionManagerMBean

getKey

protected String getKey(String prefix,
 long id)

commitOff

protected void commitOff(Space sp)

commitOn

protected void commitOn(Space sp)

checkTail

protected void checkTail()

tailDone

protected boolean tailDone()

snapshot

protected void snapshot(long id,
 Serializable context)

snapshot

protected void snapshot(long id,
 Serializable context,
 Integer status)

setState

protected void setState(long id,
 Integer state)

addGroup

protected void addGroup(long id,
 String groupName)

purge

protected void purge(long id,
 boolean full)

recover

protected void recover()

recover

protected void recover(long id)

checkRetryTask

protected void checkRetryTask()

freeze

protected LogEvent freeze(Serializable context,
 LogEvent evt,
 Profiler prof)

This method gives the opportunity to decorate a LogEvent right before it gets logged. When overriding it, unless you know what you're doing, you should return a FrozenLogEvent in order to prevent concurrency issues.

Parameters:

context - current Context

evt - current LogEvent

prof - profiler (may be null)

Returns:

FrozenLogEvent

getSessionsToStandUp

protected int getSessionsToStandUp()

This method returns the number of sessions that can be started at this point in time

Returns:

number of sessions

isSessionToStandDown

protected boolean isSessionToStandDown()

This method returns true if current session should stop working on more messages

Returns:

getActiveSessions

public int getActiveSessions()

Specified by:

getActiveSessions in interface TransactionManagerMBean

getMaxSessions

public int getMaxSessions()

Specified by:

getMaxSessions in interface TransactionManagerMBean

getSerializable

public static Serializable getSerializable()

getContext

public static <T extends Serializable> T getContext()

getId

public static Long getId()