Uses of Class
org.apache.commons.pipeline.driver.FaultTolerance

Packages that use FaultTolerance

org.apache.commons.pipeline.driver

This package contains implementations of the StageDriver and StageDriverFactory interfaces.

Uses of FaultTolerance in org.apache.commons.pipeline.driver

Fields in org.apache.commons.pipeline.driver declared as FaultTolerance

protected FaultTolerance

AbstractStageDriver.faultTolerance Enumerated value indicating the fault tolerance level of the StageDriver.

Methods in org.apache.commons.pipeline.driver that return FaultTolerance

FaultTolerance	ThreadPoolStageDriverFactory.getFaultTolerance() Getter for property faultTolerance.
FaultTolerance	SynchronousStageDriverFactory.getFaultTolerance() Getter for property faultTolerance.
FaultTolerance	DedicatedThreadStageDriverFactory.getFaultTolerance() Getter for property faultTolerance.
FaultTolerance	AbstractStageDriver.getFaultTolerance() Getter for property faultTolerant.
static FaultTolerance	FaultTolerance.valueOf(String name) Returns the enum constant of this type with the specified name.
static FaultTolerance[]	FaultTolerance.values() Returns an array containing the constants of this enum type, in the order they are declared.

Methods in org.apache.commons.pipeline.driver with parameters of type FaultTolerance

void	ThreadPoolStageDriverFactory.setFaultTolerance(FaultTolerance faultTolerance) Setter for property faultTolerance.
void	SynchronousStageDriverFactory.setFaultTolerance(FaultTolerance faultTolerance) Setter for property faultTolerance.
void	DedicatedThreadStageDriverFactory.setFaultTolerance(FaultTolerance faultTolerance) Setter for property faultTolerance.
void	AbstractStageDriver.setFaultTolerance(FaultTolerance faultTolerance) Sets the failure tolerance flag for the worker thread.

Constructors in org.apache.commons.pipeline.driver with parameters of type FaultTolerance

AbstractStageDriver(Stage stage, StageContext context, FaultTolerance faultTolerance)
Creates a StageDriver for the specified stage.

DedicatedThreadStageDriver(Stage stage, StageContext context, BlockingQueue queue, long timeout, FaultTolerance faultTolerance)
Creates a new DedicatedThreadStageDriver with the specified thread wait timeout and fault tolerance values.

SynchronousStageDriver(Stage stage, StageContext context, FaultTolerance faultTolerance)
Creates a new instance of SimpleStageDriver

ThreadPoolStageDriver(Stage stage, StageContext context, BlockingQueue queue, long timeout, FaultTolerance faultTolerance, int numThreads)
Creates a new ThreadPoolStageDriver.