Package org.apache.commons.pipeline

This package provides a set of pipeline utilities designed around work queues that run in parallel to sequentially process data objects.

See:
Description

Interface Summary

Feeder	This interface represents a data channel into which objects can be fed.
PipelineFactory	Simple factory interface for creating pipelines.
PipelineLifecycleJob	This interface specifies a job or set of tasks that are to be run at a well-specified points in the pipeline lifecycle.
Stage	A Stage represents a set of tasks that can be performed on objects in a queue, and methods used to communicate with other stages in a Pipeline.
StageContext	This interface represents the context in which a stage is run.
StageDriver	This interface is used to define how processing for a stage is started, stopped, and run.
StageDriverFactory<T extends StageDriver>	This interface represents a factory that is used by a Pipeline to create a driver for a Stage when that stage is added to the pipeline.
StageEventListener	Listener interface for EventObjects.

Class Summary

Pipeline

This class represents a processing system consisting of a number of stages and branches.

Enum Summary

StageDriver.State

This enumeration represents possible states of the a stage driver during processing.

Exception Summary

PipelineCreationException	This is a wrapper exception for use by PipelineFactorys.
ProcessingException	This exception class is used to store detailed information about a failure in the processing step of a stage including the failing data, the driver state at the time of failure, and any exceptions encountered.
StageException	Exception wrapper class for exceptions that occur while processing a stage.

Package org.apache.commons.pipeline Description

This package provides a set of pipeline utilities designed around work queues that run in parallel to sequentially process data objects.