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.



Copyright © 2004-2009 The Apache Software Foundation. All Rights Reserved.