Package org.cyclos.impl

Interface InvokerHandler

public interface InvokerHandler

Handler used to control the invocation of callbacks with a given SessionData, which can also be combined with transactions

Method Summary

Modifier and Type	Method	Description
ScheduledExecutorService	getExecutorService()	Returns the ScheduledExecutorService which can be used for running tasks in parallel.
<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)	Deprecated. Clients shouldn't await for the result by calling Future.get.
<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	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.
Throwable	translateException(Throwable t)	Translate known exceptions into Cyclos' own exceptions

Method Detail

getExecutorService

ScheduledExecutorService getExecutorService()

Returns the ScheduledExecutorService which can be used for running tasks in parallel. One example which uses this ScheduledExecutorService is runAsInParallelTransaction(SessionData, TransactionLevel, TransactionCallback).

runAs

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

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

runAsInCurrentOrNewTransaction

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

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

Throws:

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

runAsInParallelTransaction

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

Deprecated.

Clients shouldn't await for the result by calling Future.get. Use submitAsInParallelTransaction(SessionData, TransactionLevel, Consumer) instead. For scripts, use custom background tasks instead, because runAsInParallelTransaction may commit while the main transaction rolls-back, which would probably make the system inconsistent. With custom background tasks, if the main transaction rolls back, so will all the scheduled background task executions be rolled-back.

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

runAsInTransaction

<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

submitAsInParallelTransaction

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. For scripts, use custom background tasks instead, because submitAsInParallelTransaction may commit while the main transaction rolls-back, which would probably make the system inconsistent. With custom background tasks, if the main transaction rolls back, so will all the scheduled background task executions be rolled-back.

translateException

Throwable translateException(Throwable t)

Translate known exceptions into Cyclos' own exceptions