org.fcrepo.kernel.modeshape.services

Class BatchServiceImpl

java.lang.Object

org.fcrepo.kernel.modeshape.services.AbstractService

org.fcrepo.kernel.modeshape.services.BatchServiceImpl

All Implemented Interfaces:

BatchService

@Component
public class BatchServiceImpl
extends AbstractService
implements BatchService

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

Author:

frank asseg, ajs6f, acoburn

Field Summary

Fields

Modifier and Type	Field and Description
static long	REAP_INTERVAL

Constructor Summary

Constructors

Constructor and Description
BatchServiceImpl()

Method Summary

Modifier and Type	Method and Description
void	abort(String sessionId, String username) Roll back any uncommited changes during a FedoraSession
void	begin(FedoraSession session, String username) Create a new batch operation with a FedoraSession and add it to the currently open ones
void	commit(String sessionId, String username) Commit any changes during a FedoraSession with the given id and username
boolean	exists(String sessionId, String username) Check if a FedoraSession exists for a particular user
FedoraSession	getSession(String sessionId, String username) Retrieve an open FedoraSession for a given user
void	refresh(String sessionId, String username) Refresh an existing session using an implementation-defined default
void	removeExpired() Every REAP_INTERVAL milliseconds, check for expired sessions.

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

exists, findNode, findOrCreateNode

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.fcrepo.kernel.api.services.BatchService

abort, begin, commit, exists, getSession

Field Detail

REAP_INTERVAL

public static final long REAP_INTERVAL

See Also:

Constant Field Values

Constructor Detail

BatchServiceImpl

public BatchServiceImpl()

Method Detail

removeExpired

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

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

Specified by:

removeExpired in interface BatchService

begin

public void begin(FedoraSession session,
                  String username)

Description copied from interface: BatchService

Create a new batch operation with a FedoraSession and add it to the currently open ones

Specified by:

begin in interface BatchService

Parameters:

session - The session to use for this batch operation

username - the name of the Principal

getSession

public FedoraSession getSession(String sessionId,
                                String username)

Description copied from interface: BatchService

Retrieve an open FedoraSession for a given user

Specified by:

getSession in interface BatchService

Parameters:

sessionId - the Id of the FedoraSession

username - the name of the Principal

Returns:

the FedoraSession with this user

exists

public boolean exists(String sessionId,
                      String username)

Description copied from interface: BatchService

Check if a FedoraSession exists for a particular user

Specified by:

exists in interface BatchService

Parameters:

sessionId - the Id of the FedoraSession

username - the name of the Principal

Returns:

the FedoraSession object for the defined user

commit

public void commit(String sessionId,
                   String username)

Description copied from interface: BatchService

Commit any changes during a FedoraSession with the given id and username

Specified by:

commit in interface BatchService

Parameters:

sessionId - the id of the FedoraSession

username - the name of the Principal

refresh

public void refresh(String sessionId,
                    String username)

Description copied from interface: BatchService

Refresh an existing session using an implementation-defined default

Specified by:

refresh in interface BatchService

Parameters:

sessionId - the Id of the FedoraSession

username - the name of the Principal

abort

public void abort(String sessionId,
                  String username)

Description copied from interface: BatchService

Roll back any uncommited changes during a FedoraSession

Specified by:

abort in interface BatchService

Parameters:

sessionId - the id of the FedoraSession

username - the name of the Principal