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 executeFlow
StartLimitExceededException
JobRestartException
JobInterruptedException
JobExecution getJobExecution()
JobExecution
StepExecution getStepExecution()
StepExecution
or null if there is nonevoid close(FlowExecution result)
result
- the final FlowExecution
void abandonStepExecution()
void updateJobExecutionStatus(FlowExecutionStatus status)
JobExecution
.boolean isRestart()
void addExitStatus(java.lang.String code)
code
- the label for the exit status when a flow or sub-flow ends