org.kuali.ole.sys.context

Class BatchStepExecutor

java.lang.Object

org.kuali.ole.sys.context.BatchStepExecutor

All Implemented Interfaces:

Runnable

public class BatchStepExecutor
extends Object
implements Runnable

BatchStepExecutor executes a Step in its own Thread and writes either a .success or .error file after execution. This class notifies the ContainerStepListener when a Step has started and when it has completed. BatchStepExecutor adds a ConsoleAppender to its Logger if one hasn't been configured.

Constructor Summary

Constructors

Constructor and Description
BatchStepExecutor(org.kuali.rice.coreservice.framework.parameter.ParameterService parameterService, org.kuali.rice.core.api.datetime.DateTimeService dateTimeService, BatchContainerDirectory batchContainerDirectory, BatchStepFileDescriptor batchStepFile, Step step, int stepIndex)

Method Summary

Methods

Modifier and Type	Method and Description
void	addContainerStepListener(ContainerStepListener listener) Adds a ContainerStepListener for step start and completion notifications
void	run() Execute the Step via Job.runStep().

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchStepExecutor

public BatchStepExecutor(org.kuali.rice.coreservice.framework.parameter.ParameterService parameterService,
                 org.kuali.rice.core.api.datetime.DateTimeService dateTimeService,
                 BatchContainerDirectory batchContainerDirectory,
                 BatchStepFileDescriptor batchStepFile,
                 Step step,
                 int stepIndex)

Parameters:

parameterService - the ParameterService used by Job

dateTimeService - the DateTimeService used by Job

batchContainerDirectory - the batch container directory

batchStepFile - the descriptor containing information about the step to execute

step - the Step to execute

stepIndex - the index of the step in the job

Method Detail

run

public void run()

Execute the Step via Job.runStep(). Setup NDC logging so the Step has its own log file. Remove the NDC logging once the step is finished executing. Notify the ContainerStepListeners when the step starts and finishes.

Specified by:

run in interface Runnable

addContainerStepListener

public void addContainerStepListener(ContainerStepListener listener)

Adds a ContainerStepListener for step start and completion notifications

Parameters:

listener - the ContainerStepListener