fr.gouv.vitam.processing.management.core

Class ProcessManagementImpl

java.lang.Object

fr.gouv.vitam.processing.management.core.ProcessManagementImpl

All Implemented Interfaces:

ProcessLifeCycle, VitamAutoCloseable, ProcessManagement, AutoCloseable

public class ProcessManagementImpl
extends Object
implements ProcessManagement

ProcessManagementImpl implementation of ProcessManagement API

Constructor Summary

Constructors

Constructor and Description
ProcessManagementImpl(ServerConfiguration config, ProcessDistributor processDistributor) constructor of ProcessManagementImpl

Method Summary

Modifier and Type	Method and Description
ItemStatus	cancel(String operationId, Integer tenantId) Handle a cancel action for the corresponding process workflow
void	close()
List<ProcessWorkflow>	findAllProcessWorkflow(Integer tenantId) Retrieve All the workflow process for monitoring purpose The final business scope of this feature is likely to be redefined, to match the future need
ProcessWorkflow	findOneProcessWorkflow(String operationId, Integer tenantId) find the workflow process according to the operation_id and the tenant_id
ServerConfiguration	getConfiguration() server configuration
List<ProcessDetail>	getFilteredProcess(ProcessQuery query, Integer tenantId) Get filtered process workflow
Map<String,IEventsState>	getProcessMonitorList() sProcessMonitorList
Map<String,WorkFlow>	getWorkflowDefinitions() Retrieve the loaded workflow definitions
Map<Integer,Map<String,ProcessWorkflow>>	getWorkFlowList()
ProcessWorkflow	init(WorkerParameters workerParameters, String workflowId, LogbookTypeProcess logbookTypeProcess, Integer tenantId, String contextId) Init a new process workflow
ItemStatus	next(WorkerParameters workerParameters, Integer tenantId) Handle a next action for the corresponding process workflow
ItemStatus	pause(String operationId, Integer tenantId) Handle a pause action for the corresponding process workflow
void	reloadWorkflowDefinitions() Reload workflow definitions
ItemStatus	replay(WorkerParameters workerParameters, Integer tenantId) Handle a replay action for the corresponding process workflow
ItemStatus	resume(WorkerParameters workerParameters, Integer tenantId) Handle a resume action for the corresponding process workflow
void	startProcess() This method is called when the server started Start all process
void	stopProcess() This method is used to properly stop all processworklfow Call stop on all running process workflow and propagate this stop to the distributor The distributor should : - Unregister all worker and complete all opened connections to the workers - Stop properly waiting tasks - Save index of element to be used in the next start

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcessManagementImpl

public ProcessManagementImpl(ServerConfiguration config,
                             ProcessDistributor processDistributor)
                      throws ProcessingStorageWorkspaceException

constructor of ProcessManagementImpl

Parameters:

config - configuration of process engine server

processDistributor -

Throws:

ProcessingStorageWorkspaceException - thrown when error occurred on loading paused process

Method Detail

startProcess

public void startProcess()

Description copied from interface: ProcessLifeCycle

This method is called when the server started Start all process

Specified by:

startProcess in interface ProcessLifeCycle

stopProcess

public void stopProcess()

This method is used to properly stop all processworklfow Call stop on all running process workflow and propagate this stop to the distributor The distributor should : - Unregister all worker and complete all opened connections to the workers - Stop properly waiting tasks - Save index of element to be used in the next start

Specified by:

stopProcess in interface ProcessLifeCycle

init

public ProcessWorkflow init(WorkerParameters workerParameters,
                            String workflowId,
                            LogbookTypeProcess logbookTypeProcess,
                            Integer tenantId,
                            String contextId)
                     throws ProcessingException

Description copied from interface: ProcessManagement

Init a new process workflow

Specified by:

init in interface ProcessManagement

Parameters:

workerParameters - parameters to be passed to ProcessEngine

workflowId - the workflow identifier

logbookTypeProcess - the process type

tenantId - the tenant identifier

contextId - the context ID

Returns:

ProcessWorkflow

Throws:

ProcessingException - if the process could not be initialized

next

public ItemStatus next(WorkerParameters workerParameters,
                       Integer tenantId)
                throws ProcessingException,
                       StateNotAllowedException

Description copied from interface: ProcessManagement

Handle a next action for the corresponding process workflow

Specified by:

next in interface ProcessManagement

Parameters:

workerParameters - parameters to be passed to ProcessEngine

tenantId - the tenant identifier

Returns:

the status

Throws:

ProcessingException - if next could not be applied

StateNotAllowedException - if the process state is incorrect

replay

public ItemStatus replay(WorkerParameters workerParameters,
                         Integer tenantId)
                  throws ProcessingException,
                         StateNotAllowedException

Description copied from interface: ProcessManagement

Handle a replay action for the corresponding process workflow

Specified by:

replay in interface ProcessManagement

Parameters:

workerParameters - parameters to be passed to ProcessEngine

tenantId - the tenant identifier

Returns:

the status

Throws:

ProcessingException - if replay could not be applied

StateNotAllowedException - if the process state is incorrect

resume

public ItemStatus resume(WorkerParameters workerParameters,
                         Integer tenantId)
                  throws ProcessingException,
                         StateNotAllowedException

Description copied from interface: ProcessManagement

Handle a resume action for the corresponding process workflow

Specified by:

resume in interface ProcessManagement

Parameters:

workerParameters - parameters to be passed to ProcessEngine

tenantId - the tenant identifier

Returns:

the status

Throws:

ProcessingException - if resume could not be applied

StateNotAllowedException - if the process state is incorrect

pause

public ItemStatus pause(String operationId,
                        Integer tenantId)
                 throws ProcessingException,
                        StateNotAllowedException

Description copied from interface: ProcessManagement

Handle a pause action for the corresponding process workflow

Specified by:

pause in interface ProcessManagement

Parameters:

operationId - the operation identifier

tenantId - the tenant identifier

Returns:

the status

Throws:

ProcessingException - if pause could not be applied

StateNotAllowedException - if the process state is incorrect

cancel

public ItemStatus cancel(String operationId,
                         Integer tenantId)
                  throws WorkflowNotFoundException,
                         ProcessingException,
                         StateNotAllowedException

Description copied from interface: ProcessManagement

Handle a cancel action for the corresponding process workflow

Specified by:

cancel in interface ProcessManagement

Parameters:

operationId - the operation identifier

tenantId - the tenant identifier

Returns:

the status

Throws:

ProcessingException - if cancel could not be applied

StateNotAllowedException - if the process state is incorrect

WorkflowNotFoundException

close

public void close()

Specified by:

close in interface VitamAutoCloseable

Specified by:

close in interface AutoCloseable

findAllProcessWorkflow

public List<ProcessWorkflow> findAllProcessWorkflow(Integer tenantId)

Description copied from interface: ProcessManagement

Retrieve All the workflow process for monitoring purpose The final business scope of this feature is likely to be redefined, to match the future need

Specified by:

findAllProcessWorkflow in interface ProcessManagement

Parameters:

tenantId - the tenant identifier

Returns:

All the workflow process details

findOneProcessWorkflow

public ProcessWorkflow findOneProcessWorkflow(String operationId,
                                              Integer tenantId)

Description copied from interface: ProcessManagement

find the workflow process according to the operation_id and the tenant_id

Specified by:

findOneProcessWorkflow in interface ProcessManagement

Parameters:

operationId - the operation identifier

tenantId - the tenant identifier

Returns:

the workFlow process

getWorkflowDefinitions

public Map<String,WorkFlow> getWorkflowDefinitions()

Description copied from interface: ProcessManagement

Retrieve the loaded workflow definitions

Specified by:

getWorkflowDefinitions in interface ProcessManagement

Returns:

the workflow definitions by ID

reloadWorkflowDefinitions

public void reloadWorkflowDefinitions()

Description copied from interface: ProcessManagement

Reload workflow definitions

Specified by:

reloadWorkflowDefinitions in interface ProcessManagement

getWorkFlowList

public Map<Integer,Map<String,ProcessWorkflow>> getWorkFlowList()

Specified by:

getWorkFlowList in interface ProcessManagement

Returns:

WorkFlow List

getProcessMonitorList

public Map<String,IEventsState> getProcessMonitorList()

Description copied from interface: ProcessManagement

sProcessMonitorList

Specified by:

getProcessMonitorList in interface ProcessManagement

Returns:

getFilteredProcess

public List<ProcessDetail> getFilteredProcess(ProcessQuery query,
                                              Integer tenantId)

Description copied from interface: ProcessManagement

Get filtered process workflow

Specified by:

getFilteredProcess in interface ProcessManagement

Parameters:

query - to filter

tenantId - the tenandId

Returns:

filtered process list

getConfiguration

public ServerConfiguration getConfiguration()

Description copied from interface: ProcessManagement

server configuration

Specified by:

getConfiguration in interface ProcessManagement

Returns: