fr.gouv.vitam.processing.engine.core

Class ProcessEngineImpl

java.lang.Object

fr.gouv.vitam.processing.engine.core.ProcessEngineImpl

All Implemented Interfaces:

ProcessEngine

public class ProcessEngineImpl
extends Object
implements ProcessEngine

ProcessEngineImpl class manages the context and call a process distributor

Constructor Summary

Constructors

Constructor and Description
ProcessEngineImpl(WorkerParameters workerParameters, ProcessDistributor processDistributor)

Method Summary

Modifier and Type	Method and Description
boolean	cancel(String operationId) Cancel the execution of the current step Send message to the distributor to cancel the execution of the current step
boolean	pause(String operationId) Pause the execution of the current step Send message to the distributor to cancel the execution of the current step
void	setCallback(IEventsProcessEngine callback) Set the state machine where the ProcessEngine return response on complete or on error
void	start(ProcessStep step, WorkerParameters workerParameters, Map<String,String> params, PauseRecover pauseRecover) Start the execution of the given step

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcessEngineImpl

public ProcessEngineImpl(WorkerParameters workerParameters,
                         ProcessDistributor processDistributor)

Method Detail

setCallback

public void setCallback(IEventsProcessEngine callback)

Description copied from interface: ProcessEngine

Set the state machine where the ProcessEngine return response on complete or on error

Specified by:

setCallback in interface ProcessEngine

pause

public boolean pause(String operationId)

Description copied from interface: ProcessEngine

Pause the execution of the current step Send message to the distributor to cancel the execution of the current step

Specified by:

pause in interface ProcessEngine

Parameters:

operationId - the operation identifier

Returns:

true if pause applied, false else

cancel

public boolean cancel(String operationId)

Description copied from interface: ProcessEngine

Cancel the execution of the current step Send message to the distributor to cancel the execution of the current step

Specified by:

cancel in interface ProcessEngine

Parameters:

operationId - the operation identifier

Returns:

true if pause applied, false else

start

public void start(ProcessStep step,
                  WorkerParameters workerParameters,
                  Map<String,String> params,
                  PauseRecover pauseRecover)
           throws ProcessingEngineException

Description copied from interface: ProcessEngine

Start the execution of the given step

Specified by:

start in interface ProcessEngine

Parameters:

step - the ProcessStep object

workerParameters - the worker parameters

params - other parameters

pauseRecover - prevent recover from pause action

Throws:

ProcessingEngineException - thrown if step could not be started