Package | Description |
---|---|
fr.gouv.vitam.common.model |
This package contains simple POJOs and DTOs that may be shared commonly by all vitam internal components
|
fr.gouv.vitam.processing.common.automation | |
fr.gouv.vitam.processing.management.api |
Provides API classes for the Processing Management module
|
fr.gouv.vitam.processing.management.core |
Provides core implementation for the Processing Management module.
|
Modifier and Type | Method and Description |
---|---|
void |
ProcessState.eval(ProcessState processState)
Evaluate for the current state if the given state is permitted or not
|
Modifier and Type | Method and Description |
---|---|
void |
IEventsState.cancel()
Cancel as soon as possible the processWorkflow, To do that, the step pauseCancelAction is updated to be
PauseOrCancelAction.ACTION_CANCEL Unlike pause, - The finally step should be executed, -
PauseOrCancelAction.ACTION_CANCEL have no impact on the finally step - The finally step cannot be cancelled
|
void |
IEventsState.next(WorkerParameters workerParameters)
Like a resume but pause at the next step
|
void |
IEventsState.pause()
Pause the processWorkflow, If the last step the just wait the finally step Else pause the processWorkflow as soon
as possible Do not wait all elements of the current step to be executed The step pauseCancelAction will be
updated to PauseOrCancelAction.ACTION_PAUSE If all elements of the current step are executed then stop correctly
and step pauseCancelAction will be updated to PauseOrCancelAction.ACTION_COMPLETE
After next or resume occurs on paused processWorkflow, It will starts from the step pauseCancelAction equals to
PauseOrCancelAction.ACTION_PAUSE if exists and update pauseCancelAction to be PauseOrCancelAction.ACTION_RECOVER
Else starts normally from the next step
|
void |
IEventsState.replay(WorkerParameters workerParameters)
Replay the last executed step, or if it s stated, the step passed as a parameter
|
void |
IEventsState.resume(WorkerParameters workerParameters)
Do an evaluation of the State RUNNING If the state is not permitted a StateNotAllowedException is thrown Else
call doRunning method
|
void |
IEventsState.shutdown()
Should used only when server is shutting down
To prevent deadlock, this method is not synchronized, Because onComplete and onPauseOrCancel are synchronized and
called from ProcessEngine
|
Modifier and Type | Method and Description |
---|---|
ItemStatus |
ProcessManagement.cancel(String operationId,
Integer tenantId)
Handle a cancel action for the corresponding process workflow
|
ItemStatus |
ProcessManagement.next(WorkerParameters workerParameters,
Integer tenantId)
Handle a next action for the corresponding process workflow
|
ItemStatus |
ProcessManagement.pause(String operationId,
Integer tenantId)
Handle a pause action for the corresponding process workflow
|
ItemStatus |
ProcessManagement.replay(WorkerParameters workerParameters,
Integer tenantId)
Handle a replay action for the corresponding process workflow
|
ItemStatus |
ProcessManagement.resume(WorkerParameters workerParameters,
Integer tenantId)
Handle a resume action for the corresponding process workflow
|
Modifier and Type | Method and Description |
---|---|
void |
StateMachine.cancel() |
ItemStatus |
ProcessManagementImpl.cancel(String operationId,
Integer tenantId) |
protected void |
StateMachine.doCompleted()
Change the state of the process to completed Can be called only from running or pause state If running state, the
next step will be completed
|
protected void |
StateMachine.doPause(PauseRecover pauseRecover)
Change state of the process to pause Can be called only from running state If last step then change state to
completed
|
void |
StateMachine.next(WorkerParameters workerParameters) |
ItemStatus |
ProcessManagementImpl.next(WorkerParameters workerParameters,
Integer tenantId) |
void |
StateMachine.pause() |
ItemStatus |
ProcessManagementImpl.pause(String operationId,
Integer tenantId) |
void |
StateMachine.replay(WorkerParameters workerParameters) |
ItemStatus |
ProcessManagementImpl.replay(WorkerParameters workerParameters,
Integer tenantId) |
void |
StateMachine.resume(WorkerParameters workerParameters) |
ItemStatus |
ProcessManagementImpl.resume(WorkerParameters workerParameters,
Integer tenantId) |
void |
StateMachine.shutdown() |
Copyright © 2018 Vitam. All rights reserved.