Package ch.tocco.nice2.persist.core.impl.exec

Class CommandServiceImpl

java.lang.Object

ch.tocco.nice2.persist.core.impl.exec.CommandServiceImpl

All Implemented Interfaces:

CommandService

public class CommandServiceImpl
extends Object
implements CommandService

Constructor Summary

Constructors

Constructor	Description
CommandServiceImpl(org.slf4j.Logger log, PersistTaskRunner runner, Mode.Key<Boolean> modesApplied, ModeHandler handler, ExecutorService executorService, ContextManager contextManager, ThreadHandlerManager threadHandlerManager, L10N l10N, List<CommandServiceListener> listeners)

Method Summary

Modifier and Type	Method	Description
void	addListener(CommandServiceListener listener)
protected void	finalize()
void	removeListener(CommandServiceListener listener)
void	shutdown(long timeout, TimeUnit unit)
<A, T, E extends Exception> com.google.common.util.concurrent.ListenableFuture<Optional<T>>	submit(Mode<E> mode, PersistTask<A,T> task, A arg)	Submits the persist tasks for execution in a separate thread returning a ListenableFuture exposing control methods.

Methods inherited from class java.lang.Object

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

Constructor Details

CommandServiceImpl

public CommandServiceImpl(org.slf4j.Logger log,
 PersistTaskRunner runner,
 Mode.Key<Boolean> modesApplied,
 ModeHandler handler,
 ExecutorService executorService,
 ContextManager contextManager,
 ThreadHandlerManager threadHandlerManager,
 L10N l10N,
 List<CommandServiceListener> listeners)

Method Details

shutdown

public void shutdown(long timeout,
 TimeUnit unit)

finalize

protected void finalize()
                 throws Throwable

Overrides:

finalize in class Object

Throws:

Throwable

submit

public <A,
T,
E extends Exception>
com.google.common.util.concurrent.ListenableFuture<Optional<T>> submit(Mode<E> mode,
 PersistTask<A,T> task,
 @Nullable
 A arg)

Description copied from interface: CommandService

Submits the persist tasks for execution in a separate thread returning a ListenableFuture exposing control methods. The task is executed exactly as CommandExecutor.perform(Mode, PersistTask, Object).

By default, the security context of the calling thread is restored for the thread executing the persist task.

Specified by:

submit in interface CommandService

Parameters:

mode - the mode used for execution

task - the task to execute asynchronously

arg - the argument that is passed to the task

addListener

public void addListener(CommandServiceListener listener)

Specified by:

addListener in interface CommandService

removeListener

public void removeListener(CommandServiceListener listener)

Specified by:

removeListener in interface CommandService