Package io.vertigo.orchestra.plugins.services.execution.memory

Class MemoryProcessExecutorPlugin

java.lang.Object

io.vertigo.orchestra.plugins.services.execution.memory.MemoryProcessExecutorPlugin

All Implemented Interfaces:

io.vertigo.core.node.component.Activeable, io.vertigo.core.node.component.CoreComponent, io.vertigo.core.node.component.Plugin, ProcessExecutorPlugin, ProcessExecutor

public class MemoryProcessExecutorPlugin
extends Object
implements ProcessExecutorPlugin, io.vertigo.core.node.component.Activeable

Executeur de processus non supervisés.

Author:

mlaroche

Constructor Summary

Constructors

Constructor	Description
MemoryProcessExecutorPlugin(Integer workersCount)	Constructeur de l'executeur simple local.

Method Summary

Modifier and Type	Method	Description
void	endPendingActivityExecution(Long activityExecutionId, String token, ExecutionState state, Optional<String> errorMessageOpt)	Termine une execution mise en attente.
void	execute(ProcessDefinition processDefinition, Optional<String> initialParams)	Execute un processus.
ProcessType	getHandledProcessType()	Retourne le type de processus géré par le plugin
void	setActivityExecutionPending(Long activityExecutionId, ActivityExecutionWorkspace workspace)	Mets une execution en attente.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Details

MemoryProcessExecutorPlugin

@Inject
public MemoryProcessExecutorPlugin(Integer workersCount)

Constructeur de l'executeur simple local.

Parameters:

workersCount - le nombre de workers du pool

Method Details

start

public void start()

Specified by:

start in interface io.vertigo.core.node.component.Activeable

stop

public void stop()

Specified by:

stop in interface io.vertigo.core.node.component.Activeable

execute

public void execute(ProcessDefinition processDefinition,
 Optional<String> initialParams)

Description copied from interface: ProcessExecutor

Execute un processus.

Specified by:

execute in interface ProcessExecutor

Parameters:

processDefinition - le processus à lancer

initialParams - paramètres initiaux supplémentaires

getHandledProcessType

public ProcessType getHandledProcessType()

Description copied from interface: ProcessExecutorPlugin

Retourne le type de processus géré par le plugin

Specified by:

getHandledProcessType in interface ProcessExecutorPlugin

Returns:

le type de processus géré

endPendingActivityExecution

public void endPendingActivityExecution(Long activityExecutionId,
 String token,
 ExecutionState state,
 Optional<String> errorMessageOpt)

Description copied from interface: ProcessExecutor

Termine une execution mise en attente.

Specified by:

endPendingActivityExecution in interface ProcessExecutor

Parameters:

activityExecutionId - L'id de l'execution à terminer

token - Le ticket associé permettant de s'assurer que n'importe qui ne termine pas une activity (seulement un callback)

state - L'état futur de l'activité

setActivityExecutionPending

public void setActivityExecutionPending(Long activityExecutionId,
 ActivityExecutionWorkspace workspace)

Description copied from interface: ProcessExecutor

Mets une execution en attente.

Specified by:

setActivityExecutionPending in interface ProcessExecutor

Parameters:

activityExecutionId - L'id de l'execution à mettre en attente

workspace - Le workspace avant la mise en attente