teetime.stage.basic.distributor

Class Distributor<T>

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractConsumerStage<T>

teetime.stage.basic.distributor.Distributor<T>

Type Parameters:

T - the type of both the input and output ports

Direct Known Subclasses:

DynamicDistributor

public class Distributor<T>
extends AbstractConsumerStage<T>

New output ports can be created by calling getNewOutputPort().

Since:

1.0

Author:

Christian Wulf, Nelson Tavares de Sousa

Stage output:

The incoming element will be passed to output ports, which are selected by a strategy.

Stage sketch:

     +----------------------------+
     |                            |
     |                          +---+
     |           +------------> |   |
     |           |              +---+
     |           |                |
   +---+         |
   |   | +-------+--- . . .       .
   +---+         |
     |           |                |
     |           |              +---+
     |           +------------> |   |
     |                          +---+
     |                            |
     +----------------------------+
               

Field Summary

Fields

Modifier and Type	Field and Description
protected IDistributorStrategy	strategy

Fields inherited from class teetime.framework.AbstractConsumerStage

inputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
Distributor()
Distributor(IDistributorStrategy strategy)

Method Summary

Modifier and Type	Method and Description
protected void	execute(T element) Contains the logic of this stage and is invoked (possibly multiple times) by the framework.
OutputPort<T>	getNewOutputPort()
List<OutputPort<?>>	getOutputPorts()
IDistributorStrategy	getStrategy()
void	setStrategy(IDistributorStrategy strategy)

Methods inherited from class teetime.framework.AbstractConsumerStage

createInputPort, execute, getInputPort

Methods inherited from class teetime.framework.AbstractStage

abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, executeByFramework, getCurrentState, getId, getInputPorts, getOwningThread, getTerminationStrategy, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, onStarting, onTerminating, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted

Methods inherited from class java.lang.Object

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

Field Detail

strategy

protected IDistributorStrategy strategy

Constructor Detail

Distributor

public Distributor()

Distributor

public Distributor(IDistributorStrategy strategy)

Method Detail

execute

protected void execute(T element)

Description copied from class: AbstractConsumerStage

Contains the logic of this stage and is invoked (possibly multiple times) by the framework.

Specified by:

execute in class AbstractConsumerStage<T>

Parameters:

element - the next non-null element from the (only) input port of this stage

getNewOutputPort

public OutputPort<T> getNewOutputPort()

getStrategy

public IDistributorStrategy getStrategy()

setStrategy

public void setStrategy(IDistributorStrategy strategy)

getOutputPorts

public List<OutputPort<?>> getOutputPorts()

Overrides:

getOutputPorts in class AbstractStage