teetime.framework

Class AbstractProducerStage<O>

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractProducerStage<O>

Type Parameters:

O - the type of the default output port

Direct Known Subclasses:

AbstractTcpReaderStage, Clock, InitialElementProducer, ObjectProducer, RandomIntegerGenerator, ResponsiveProducer, StreamProducer

public abstract class AbstractProducerStage<O>
extends AbstractStage

The ProducerStage produces at least one element at each execution.

Author:

Christian Wulf

Field Summary

Fields

Modifier and Type	Field and Description
protected OutputPort<O>	outputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
AbstractProducerStage()
AbstractProducerStage(org.slf4j.Logger logger)

Method Summary

Modifier and Type	Method and Description
OutputPort<O>	getOutputPort()
TerminationStrategy	getTerminationStrategy() Deprecated. since 3.0. We will completely remove framework-backed support for infinite producers since it has never worked correctly in all (corner) cases. Instead, please use finite producers and implement an appropriate termination condition by your own.

Methods inherited from class teetime.framework.AbstractStage

abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, execute, executeByFramework, getCurrentState, getId, getInputPorts, getOutputPorts, getOwningThread, 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

outputPort

protected final OutputPort<O> outputPort

Constructor Detail

AbstractProducerStage

public AbstractProducerStage()

AbstractProducerStage

public AbstractProducerStage(org.slf4j.Logger logger)

Parameters:

logger - a custom logger (potentially shared by multiple stage instances)

Method Detail

getOutputPort

public final OutputPort<O> getOutputPort()

getTerminationStrategy

@Deprecated
public TerminationStrategy getTerminationStrategy()

Deprecated. since 3.0. We will completely remove framework-backed support for infinite producers since it has never worked correctly in all (corner) cases. Instead, please use finite producers and implement an appropriate termination condition by your own.

Overrides:

getTerminationStrategy in class AbstractStage

Returns:

the termination strategy of this stage