org.fcrepo.kernel.impl.services

Class TransactionServiceImpl

java.lang.Object

org.fcrepo.kernel.impl.services.AbstractService

org.fcrepo.kernel.impl.services.TransactionServiceImpl

All Implemented Interfaces:

TransactionService

@Component
public class TransactionServiceImpl
extends AbstractService
implements TransactionService

This is part of the strawman implementation for Fedora transactions This service implements a simple Transaction service which is able to create/commit/rollback Transaction objects A Scheduled annotation is used for removing timed out Transactions

Author:

frank asseg

Field Summary

Fields

Modifier and Type	Field and Description
static long	REAP_INTERVAL

Fields inherited from class org.fcrepo.kernel.impl.services.AbstractService

jcrTools

Constructor Summary

Constructors

Constructor and Description
TransactionServiceImpl()

Method Summary

Methods

Modifier and Type	Method and Description
Transaction	beginTransaction(javax.jcr.Session sess, String userName) Create a new Transaction and add it to the currently open ones
Transaction	commit(String txid) Commit a Transaction with the given id
boolean	exists(String txid) Check if a Transaction exists
static String	getCurrentTransactionId(javax.jcr.Session session) Get the current Transaction ID for a session
Transaction	getTransaction(javax.jcr.Session session) Get the current Transaction for a session
Transaction	getTransaction(String txId, String userName) Recieve an open Transaction for a given user
static boolean	isInTransaction(javax.jcr.Session session) Check if a session is possibly within a transaction
void	removeAndRollbackExpired() Every REAP_INTERVAL milliseconds, check for expired transactions.
Transaction	rollback(String txid) Roll a Transaction back

Methods inherited from class org.fcrepo.kernel.impl.services.AbstractService

exists, findNode, findOrCreateNode

Methods inherited from class java.lang.Object

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

Field Detail

REAP_INTERVAL

public static final long REAP_INTERVAL

See Also:

Constant Field Values

Constructor Detail

TransactionServiceImpl

public TransactionServiceImpl()

Method Detail

isInTransaction

public static boolean isInTransaction(javax.jcr.Session session)

Check if a session is possibly within a transaction

Parameters:

session -

Returns:

removeAndRollbackExpired

@Scheduled(fixedRate=1000L)
public void removeAndRollbackExpired()

Every REAP_INTERVAL milliseconds, check for expired transactions. If the tx is expired, roll it back and remove it from the registry.

Specified by:

removeAndRollbackExpired in interface TransactionService

beginTransaction

public Transaction beginTransaction(javax.jcr.Session sess,
                           String userName)

Create a new Transaction and add it to the currently open ones

Specified by:

beginTransaction in interface TransactionService

Parameters:

sess - The session to use for this Transaction

Returns:

the Transaction

getTransaction

public Transaction getTransaction(String txId,
                         String userName)
                           throws TransactionMissingException

Description copied from interface: TransactionService

Recieve an open Transaction for a given user

Specified by:

getTransaction in interface TransactionService

Parameters:

txId - the Id of the Transaction

userName - the name of the Principal

Returns:

the Transaction

Throws:

TransactionMissingException - if the transaction could not be found or is not associated with this user

getTransaction

public Transaction getTransaction(javax.jcr.Session session)
                           throws TransactionMissingException

Get the current Transaction for a session

Specified by:

getTransaction in interface TransactionService

Parameters:

session -

Returns:

the given session's current Transaction

Throws:

TransactionMissingException

getCurrentTransactionId

public static String getCurrentTransactionId(javax.jcr.Session session)

Get the current Transaction ID for a session

Parameters:

session -

Returns:

the current Transaction ID for the given session

exists

public boolean exists(String txid)

Check if a Transaction exists

Specified by:

exists in interface TransactionService

Parameters:

txid - the Id of the Transaction

Returns:

the Transaction

commit

public Transaction commit(String txid)

Commit a Transaction with the given id

Specified by:

commit in interface TransactionService

Parameters:

txid - the id of the Transaction

rollback

public Transaction rollback(String txid)

Roll a Transaction back

Specified by:

rollback in interface TransactionService

Parameters:

txid - the id of the Transaction

Returns:

the Transaction object