org.jberet.runtime.runner

Class CompositeExecutionRunner<C extends AbstractContext>

java.lang.Object

org.jberet.runtime.runner.AbstractRunner<C>

org.jberet.runtime.runner.CompositeExecutionRunner<C>

All Implemented Interfaces:

Runnable, JobTask

Direct Known Subclasses:

FlowExecutionRunner, JobExecutionRunner, SplitExecutionRunner

public abstract class CompositeExecutionRunner<C extends AbstractContext>
extends AbstractRunner<C>

A runner for job elements that can contain other job elements. Examples of such composite job elements are job, flow and split.

Field Summary

Fields inherited from class org.jberet.runtime.runner.AbstractRunner

batchContext, enclosingRunner, id, jobContext

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	CompositeExecutionRunner(C batchContext, CompositeExecutionRunner enclosingRunner)

Method Summary

Modifier and Type	Method and Description
protected abstract List<? extends JobElement>	getJobElements()
protected void	runDecision(Decision decision, javax.batch.runtime.StepExecution... precedingStepExecutions)
protected void	runFlow(Flow flow, CountDownLatch latch)
protected void	runFromHeadOrRestartPoint(String restartPoint) Runs the first job element, which then transitions to the next element.
protected void	runJobElement(String jobElementName, javax.batch.runtime.StepExecution... precedingStepExecutions) Runs the job element including step, decision, flow, and split.
protected void	runSplit(Split split)
protected void	runStep(Step step)

Methods inherited from class org.jberet.runtime.runner.AbstractRunner

getRequiredRemainingPermits, matches, resolveTransitionElements

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Runnable

run

Constructor Detail

CompositeExecutionRunner

protected CompositeExecutionRunner(C batchContext,
                                   CompositeExecutionRunner enclosingRunner)

Method Detail

getJobElements

protected abstract List<? extends JobElement> getJobElements()

runFromHeadOrRestartPoint

protected void runFromHeadOrRestartPoint(String restartPoint)

Runs the first job element, which then transitions to the next element. Not used for running split, whose component elements are not sequential.

runJobElement

protected void runJobElement(String jobElementName,
                             javax.batch.runtime.StepExecution... precedingStepExecutions)

Runs the job element including step, decision, flow, and split.

Parameters:

jobElementName - ref name of the job element

precedingStepExecutions - 0 or 1 StepExecution, 1 StepExecution is passed in for decision element, and 0 StepExecution for others.

runStep

protected void runStep(Step step)

runDecision

protected void runDecision(Decision decision,
                           javax.batch.runtime.StepExecution... precedingStepExecutions)

runFlow

protected void runFlow(Flow flow,
                       CountDownLatch latch)

runSplit

protected void runSplit(Split split)