Package org.cyclos.impl

Interface InvokerHandler

All Known Implementing Classes:

InvokerHandlerImpl

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
ExecutorService	getExecutorService()	Returns the ExecutorService used to run transactions 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
default Throwable	translateException(Throwable t)	Translate known exceptions into Cyclos' own exceptions

Method Detail

getExecutorService

ExecutorService getExecutorService()

Returns the ExecutorService used to run transactions in parallel

See Also:

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, TransactionCallback) instead

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

translateException

default Throwable translateException(Throwable t)

Translate known exceptions into Cyclos' own exceptions