teetime.stage

Class ObjectProducer<T>

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractProducerStage<T>

teetime.stage.ObjectProducer<T>

Deprecated.

since 3.0. Use StreamProducer instead.

@Deprecated
public class ObjectProducer<T>
extends AbstractProducerStage<T>

Since:

1.0

Author:

Christian Wulf

Field Summary

Fields inherited from class teetime.framework.AbstractProducerStage

outputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
ObjectProducer(long numInputObjects, ConstructorClosure<T> inputObjectCreator) Deprecated.

Method Summary

Modifier and Type	Method and Description
protected void	execute() Deprecated. Contains the logic of this stage and is invoked (possibly multiple times) by the framework.
ConstructorClosure<T>	getInputObjectCreator() Deprecated.
long	getNumInputObjects() Deprecated.
void	setInputObjectCreator(ConstructorClosure<T> inputObjectCreator) Deprecated.
void	setNumInputObjects(long numInputObjects) Deprecated.

Methods inherited from class teetime.framework.AbstractProducerStage

getOutputPort, getTerminationStrategy

Methods inherited from class teetime.framework.AbstractStage

abort, addInputPortRemovedListener, addOutputPortRemovedListener, compareAndSetBeingExecuted, createInputPort, createInputPort, createInputPort, createInputPort, createOutputPort, createOutputPort, createOutputPort, createOutputPort, declareActive, declarePassive, 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

Constructor Detail

ObjectProducer

public ObjectProducer(long numInputObjects,
                      ConstructorClosure<T> inputObjectCreator)

Deprecated.

Parameters:

numInputObjects - number of objects which should be instantiated and sent

inputObjectCreator - a ConstructorClosure which creates the new instances

Since:

1.0

Method Detail

getNumInputObjects

public long getNumInputObjects()

Deprecated.

setNumInputObjects

public void setNumInputObjects(long numInputObjects)

Deprecated.

getInputObjectCreator

public ConstructorClosure<T> getInputObjectCreator()

Deprecated.

setInputObjectCreator

public void setInputObjectCreator(ConstructorClosure<T> inputObjectCreator)

Deprecated.

execute

protected void execute()

Deprecated.

Description copied from class: AbstractStage

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

Specified by:

execute in class AbstractStage