public interface FlowExecutor
FlowJob to allow it to delegate
its execution step by step.| Modifier and Type | Method and Description |
|---|---|
void |
abandonStepExecution()
Handle any status changes that might be needed at the start of a state.
|
void |
addExitStatus(java.lang.String code) |
void |
close(FlowExecution result)
Chance to clean up resources at the end of a flow (whether it completed
successfully or not).
|
java.lang.String |
executeStep(Step step) |
JobExecution |
getJobExecution() |
StepExecution |
getStepExecution() |
boolean |
isRestart() |
void |
updateJobExecutionStatus(FlowExecutionStatus status)
Handle any status changes that might be needed in the
JobExecution. |
java.lang.String executeStep(Step step) throws JobInterruptedException, JobRestartException, StartLimitExceededException
step - a Step to executeFlowStartLimitExceededException - thrown if start limit is exceeded.JobRestartException - thrown if job restart is not allowed.JobInterruptedException - thrown if job was interrupted.JobExecution getJobExecution()
JobExecution@Nullable StepExecution getStepExecution()
StepExecution or null if there is nonevoid close(FlowExecution result)
result - the final FlowExecutionvoid abandonStepExecution()
void updateJobExecutionStatus(FlowExecutionStatus status)
JobExecution.status - status to update the JobExecution to.boolean isRestart()
void addExitStatus(java.lang.String code)
code - the label for the exit status when a flow or sub-flow ends