public class JobFlowExecutor extends Object implements FlowExecutor
FlowExecutor
for use in components that need to
execute a flow related to a JobExecution
.Constructor and Description |
---|
JobFlowExecutor(JobRepository jobRepository,
StepHandler stepHandler,
JobExecution execution) |
Modifier and Type | Method and Description |
---|---|
void |
abandonStepExecution()
Handle any status changes that might be needed at the start of a state.
|
void |
addExitStatus(String code) |
void |
close(FlowExecution result)
Chance to clean up resources at the end of a flow (whether it completed
successfully or not).
|
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 . |
public JobFlowExecutor(JobRepository jobRepository, StepHandler stepHandler, JobExecution execution)
execution
- public String executeStep(Step step) throws JobInterruptedException, JobRestartException, StartLimitExceededException
executeStep
in interface FlowExecutor
step
- a Step
to executeFlow
JobInterruptedException
JobRestartException
StartLimitExceededException
public void abandonStepExecution()
FlowExecutor
abandonStepExecution
in interface FlowExecutor
public void updateJobExecutionStatus(FlowExecutionStatus status)
FlowExecutor
JobExecution
.updateJobExecutionStatus
in interface FlowExecutor
public JobExecution getJobExecution()
getJobExecution
in interface FlowExecutor
JobExecution
public StepExecution getStepExecution()
getStepExecution
in interface FlowExecutor
StepExecution
or null if there is nonepublic void close(FlowExecution result)
FlowExecutor
close
in interface FlowExecutor
result
- the final FlowExecution
public boolean isRestart()
isRestart
in interface FlowExecutor
public void addExitStatus(String code)
addExitStatus
in interface FlowExecutor
code
- the label for the exit status when a flow or sub-flow endsCopyright © 2014 Pivotal. All rights reserved.