org.apache.commons.pipeline.driver
Class DedicatedThreadStageDriverFactory

java.lang.Object
  org.apache.commons.pipeline.driver.DedicatedThreadStageDriverFactory

All Implemented Interfaces:

StageDriverFactory

public class DedicatedThreadStageDriverFactory
extends Object
implements StageDriverFactory

This factory is used to create DedicatedThreadStageDriver instances configured to run specific stages.

Constructor Summary

DedicatedThreadStageDriverFactory()
Creates a new instance of DedicatedThreadStageDriverFactory

Method Summary

StageDriver	createStageDriver(Stage stage, StageContext context) Creates the new DedicatedThreadStageDriver based upon the configuration of this factory instance
FaultTolerance	getFaultTolerance() Getter for property faultTolerance.
BlockingQueueFactory<?>	getQueueFactory() Getter for property queueFactory.
long	getTimeout() Timeout (in milliseconds) for queue polling to ensure deadlock cannot occur on thread termination.
void	setFaultTolerance(FaultTolerance faultTolerance) Setter for property faultTolerance.
void	setFaultToleranceLevel(String level) Convenience setter for property faultTolerance for use by Digester.
void	setQueueFactory(BlockingQueueFactory<?> queueFactory) Setter for property queueFactory.
void	setTimeout(long timeout) Setter for property timeout.

Methods inherited from class java.lang.Object

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

Constructor Detail

DedicatedThreadStageDriverFactory

public DedicatedThreadStageDriverFactory()

Creates a new instance of DedicatedThreadStageDriverFactory

Method Detail

createStageDriver

public StageDriver createStageDriver(Stage stage,
                                     StageContext context)

Creates the new DedicatedThreadStageDriver based upon the configuration of this factory instance

Specified by:

createStageDriver in interface StageDriverFactory

Parameters:

stage - The stage to be run by the newly created driver

context - The context in which the stage will be run

Returns:

the newly created driver

getTimeout

public long getTimeout()

Timeout (in milliseconds) for queue polling to ensure deadlock cannot occur on thread termination. Default value is 500 ms.

Returns:

Value of property timeout.

setTimeout

public void setTimeout(long timeout)

Setter for property timeout.

Parameters:

timeout - New value of property timeout.

getFaultTolerance

public FaultTolerance getFaultTolerance()

Getter for property faultTolerance. See FaultTolerance for valid values and enumation meanings.

Returns:

Value of property faultTolerance.

setFaultTolerance

public void setFaultTolerance(FaultTolerance faultTolerance)

Setter for property faultTolerance.

Parameters:

faultTolerance - New value of property faultTolerance.

setFaultToleranceLevel

public void setFaultToleranceLevel(String level)

Convenience setter for property faultTolerance for use by Digester.

Parameters:

level - New value of property level ("ALL","CHECKED", or "NONE").

getQueueFactory

public BlockingQueueFactory<?> getQueueFactory()

Getter for property queueFactory.

Returns:

Value of property queueFactory.

setQueueFactory

public void setQueueFactory(BlockingQueueFactory<?> queueFactory)

Setter for property queueFactory.

Parameters:

queueFactory - New value of property queueFactory.