Package org.cyclos.impl

Class InvokerHandlerImpl

java.lang.Object

org.cyclos.impl.AbstractServerComponent

org.cyclos.impl.AbstractGlobalServerComponent

org.cyclos.impl.BaseGlobalHandlerImpl

org.cyclos.impl.InvokerHandlerImpl

All Implemented Interfaces:

InvokerHandler

@Component
public class InvokerHandlerImpl
extends BaseGlobalHandlerImpl
implements InvokerHandler

Implementation for InvokerHandler

Field Summary

Fields inherited from class org.cyclos.impl.AbstractGlobalServerComponent

rawEntityManagerHandler

Fields inherited from class org.cyclos.impl.AbstractServerComponent

accountHandler, configurationHandler, dataTranslationHandler, notificationHandler, profileFieldHandler, transactionHandler, translationHandler

Constructor Summary

Constructors

Constructor	Description
InvokerHandlerImpl()

Method Summary

Modifier and Type	Method	Description
ExecutorService	getExecutorService()	Returns the ExecutorService used to run transactions in parallel
void	initialize()
<T> T	runAs(SessionData sessionData, Callable<T> callable)	Runs the given Callable using the given SessionData, within the caller's transaction
<T> T	runAsInCurrentOrNewTransaction(SessionData sessionData, TransactionLevel level, TransactionCallback<T> callback)	If there is a transaction in the current thread with a compatible transaction level as the given one, runs the given transaction callback in the current transaction.
<T> Future<T>	runAsInParallelTransaction(SessionData sessionData, TransactionLevel transactionLevel, TransactionCallback<T> callback)	Submits a new transaction to be executed in a new thread, with the given TransactionLevel, within the context of the given SessionData
<T> T	runAsInTransaction(SessionData sessionData, TransactionLevel transactionLevel, TransactionCallback<T> callback)	Runs the given TransactionCallback in a transaction in the current thread, with the given TransactionLevel, within the context of the given SessionData
void	shutdown()
void	submitAsInParallelTransaction(SessionData sessionData, TransactionLevel transactionLevel, Consumer<TransactionStatus> callback)	Submits a new transaction to be executed in a new thread, with the given TransactionLevel, within the context of the given SessionData

Methods inherited from class org.cyclos.impl.AbstractGlobalServerComponent

getBaseEntityManagerHandler, getEntityManager

Methods inherited from class org.cyclos.impl.AbstractServerComponent

dataTranslationProxy, dataTranslationProxy, delete, detach, doDataTranslationProxy, find, flush, from, getApplicationContext, getFormatter, getFormatter, getFormatter, getLogger, getRemoteAddress, getSessionData, mailContentBuilder, message, message, persist, processBatch, processBatch, refresh, remove, selectFrom, subQuery, update

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.cyclos.impl.InvokerHandler

translateException

Constructor Detail

InvokerHandlerImpl

public InvokerHandlerImpl()

Method Detail

getExecutorService

public ExecutorService getExecutorService()

Description copied from interface: InvokerHandler

Returns the ExecutorService used to run transactions in parallel

Specified by:

getExecutorService in interface InvokerHandler

See Also:

InvokerHandler.runAsInParallelTransaction(SessionData, TransactionLevel, TransactionCallback)

initialize

@PostConstruct
public void initialize()

runAs

public <T> T runAs(SessionData sessionData,
                   Callable<T> callable)

Description copied from interface: InvokerHandler

Runs the given Callable using the given SessionData, within the caller's transaction

Specified by:

runAs in interface InvokerHandler

runAsInCurrentOrNewTransaction

public <T> T runAsInCurrentOrNewTransaction(SessionData sessionData,
                                            TransactionLevel level,
                                            TransactionCallback<T> callback)
                                     throws RetryException

Description copied from interface: InvokerHandler

If there is a transaction in the current thread with a compatible transaction level as the given one, runs the given transaction callback in the current transaction. Otherwise, throws a RetryException to force a new transaction with the given level to be created, so the next time it will be compatible

Specified by:

runAsInCurrentOrNewTransaction in interface InvokerHandler

Throws:

RetryException - If the current transaction level is not compatible with the given one

runAsInParallelTransaction

public <T> Future<T> runAsInParallelTransaction(SessionData sessionData,
                                                TransactionLevel transactionLevel,
                                                TransactionCallback<T> callback)

Description copied from interface: InvokerHandler

Submits a new transaction to be executed in a new thread, with the given TransactionLevel, within the context of the given SessionData

Specified by:

runAsInParallelTransaction in interface InvokerHandler

runAsInTransaction

public <T> T runAsInTransaction(SessionData sessionData,
                                TransactionLevel transactionLevel,
                                TransactionCallback<T> callback)

Description copied from interface: InvokerHandler

Runs the given TransactionCallback in a transaction in the current thread, with the given TransactionLevel, within the context of the given SessionData

Specified by:

runAsInTransaction in interface InvokerHandler

shutdown

@PreDestroy
public void shutdown()

submitAsInParallelTransaction

public void submitAsInParallelTransaction(SessionData sessionData,
                                          TransactionLevel transactionLevel,
                                          Consumer<TransactionStatus> callback)

Description copied from interface: InvokerHandler

Submits a new transaction to be executed in a new thread, with the given TransactionLevel, within the context of the given SessionData

Specified by:

submitAsInParallelTransaction in interface InvokerHandler