nl.nn.adapterframework.jta

Class StatusRecordingTransactionManager

java.lang.Object

org.springframework.transaction.support.AbstractPlatformTransactionManager

org.springframework.transaction.jta.JtaTransactionManager

nl.nn.adapterframework.jta.ThreadConnectableJtaTransactionManager

nl.nn.adapterframework.jta.StatusRecordingTransactionManager

All Implemented Interfaces:

Serializable, IThreadConnectableTransactionManager<Object,Object>, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.transaction.jta.TransactionFactory, org.springframework.transaction.PlatformTransactionManager, org.springframework.transaction.TransactionManager

Direct Known Subclasses:

BtmJtaTransactionManager, NarayanaJtaTransactionManager

public abstract class StatusRecordingTransactionManager
extends ThreadConnectableJtaTransactionManager
implements org.springframework.beans.factory.DisposableBean

JtaTransactionManager-wrapper that enables to recover transaction logs produced by another instance.

Author:

Gerrit van Brakel

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	StatusRecordingTransactionManager.Status

Nested classes/interfaces inherited from class org.springframework.transaction.support.AbstractPlatformTransactionManager

org.springframework.transaction.support.AbstractPlatformTransactionManager.SuspendedResourcesHolder

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.logging.log4j.Logger	log

Fields inherited from class org.springframework.transaction.jta.JtaTransactionManager

DEFAULT_TRANSACTION_SYNCHRONIZATION_REGISTRY_NAME, DEFAULT_USER_TRANSACTION_NAME, FALLBACK_TRANSACTION_MANAGER_NAMES

Fields inherited from class org.springframework.transaction.support.AbstractPlatformTransactionManager

logger, SYNCHRONIZATION_ALWAYS, SYNCHRONIZATION_NEVER, SYNCHRONIZATION_ON_ACTUAL_TRANSACTION

Constructor Summary

Constructors

Constructor and Description
StatusRecordingTransactionManager()

Method Summary

Modifier and Type	Method and Description
protected abstract TransactionManager	createTransactionManager()
void	destroy()
protected String	determineTmUid()
String	read(String filename)
protected TransactionManager	retrieveTransactionManager()
protected abstract boolean	shutdownTransactionManager() Shutdown the transaction manager, attempting to complete all running transactions.
void	write(String filename, String text)
void	writeStatus(StatusRecordingTransactionManager.Status status)

Methods inherited from class nl.nn.adapterframework.jta.ThreadConnectableJtaTransactionManager

getCurrentTransaction, resumeTransaction, suspendTransaction

Methods inherited from class org.springframework.transaction.jta.JtaTransactionManager

afterPropertiesSet, applyIsolationLevel, applyTimeout, buildUserTransaction, checkUserTransactionAndTransactionManager, createTransaction, doBegin, doCleanupAfterCompletion, doCommit, doGetJtaTransaction, doGetTransaction, doJtaBegin, doJtaResume, doJtaSuspend, doRegisterAfterCompletionWithJtaTransaction, doResume, doRollback, doSetRollbackOnly, doSuspend, findTransactionManager, findTransactionSynchronizationRegistry, findUserTransaction, getJndiEnvironment, getJndiTemplate, getTransactionManager, getTransactionSynchronizationRegistry, getUserTransaction, initTransactionSynchronizationRegistry, initUserTransactionAndTransactionManager, isExistingTransaction, lookupTransactionManager, lookupTransactionSynchronizationRegistry, lookupUserTransaction, registerAfterCompletionWithExistingTransaction, retrieveTransactionSynchronizationRegistry, retrieveUserTransaction, setAllowCustomIsolationLevels, setAutodetectTransactionManager, setAutodetectTransactionSynchronizationRegistry, setAutodetectUserTransaction, setCacheUserTransaction, setJndiEnvironment, setJndiTemplate, setTransactionManager, setTransactionManagerName, setTransactionSynchronizationRegistry, setTransactionSynchronizationRegistryName, setUserTransaction, setUserTransactionName, shouldCommitOnGlobalRollbackOnly, supportsResourceAdapterManagedTransactions, useSavepointForNestedTransaction

Methods inherited from class org.springframework.transaction.support.AbstractPlatformTransactionManager

commit, determineTimeout, getDefaultTimeout, getTransaction, getTransactionSynchronization, invokeAfterCompletion, isFailEarlyOnGlobalRollbackOnly, isGlobalRollbackOnParticipationFailure, isNestedTransactionAllowed, isRollbackOnCommitFailure, isValidateExistingTransaction, newTransactionStatus, prepareForCommit, prepareSynchronization, prepareTransactionStatus, resume, rollback, setDefaultTimeout, setFailEarlyOnGlobalRollbackOnly, setGlobalRollbackOnParticipationFailure, setNestedTransactionAllowed, setRollbackOnCommitFailure, setTransactionSynchronization, setTransactionSynchronizationName, setValidateExistingTransaction, suspend, triggerBeforeCommit, triggerBeforeCompletion

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.transaction.PlatformTransactionManager

commit, getTransaction, rollback

Field Detail

log

protected org.apache.logging.log4j.Logger log

Constructor Detail

StatusRecordingTransactionManager

public StatusRecordingTransactionManager()

Method Detail

createTransactionManager

protected abstract TransactionManager createTransactionManager()
                                                        throws org.springframework.transaction.TransactionSystemException

Throws:

org.springframework.transaction.TransactionSystemException

shutdownTransactionManager

protected abstract boolean shutdownTransactionManager()
                                               throws org.springframework.transaction.TransactionSystemException

Shutdown the transaction manager, attempting to complete all running transactions.

Returns:

true if a successful shutdown took place, or false if any transactions are pending that need to be recovered later.

Throws:

org.springframework.transaction.TransactionSystemException

retrieveTransactionManager

protected TransactionManager retrieveTransactionManager()
                                                 throws org.springframework.transaction.TransactionSystemException

Overrides:

retrieveTransactionManager in class org.springframework.transaction.jta.JtaTransactionManager

Throws:

org.springframework.transaction.TransactionSystemException

determineTmUid

protected String determineTmUid()

destroy

public void destroy()

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

writeStatus

public void writeStatus(StatusRecordingTransactionManager.Status status)
                 throws org.springframework.transaction.TransactionSystemException

Throws:

org.springframework.transaction.TransactionSystemException

write

public void write(String filename,
                  String text)
           throws org.springframework.transaction.TransactionSystemException

Throws:

org.springframework.transaction.TransactionSystemException

read

public String read(String filename)