teetime.stage

Class MultipleInstanceOfFilter<I>

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractConsumerStage<I>

teetime.stage.MultipleInstanceOfFilter<I>

public final class MultipleInstanceOfFilter<I>
extends AbstractConsumerStage<I>

Author:

Nils Christian Ehmke

Field Summary

Fields inherited from class teetime.framework.AbstractConsumerStage

inputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
MultipleInstanceOfFilter()

Method Summary

Modifier and Type	Method and Description
protected void	execute(I element) Contains the logic of this stage and is invoked (possibly multiple times) by the framework.
<T extends I> OutputPort<T>	getOutputPortForType(Class<T> clazz)
void	onStarting() Event that is triggered, if all of the following conditions hold: after passing the validation phase and after the threads are ready-to-run and just before the threads execute any stage.

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, getOutputPorts, getOwningThread, getTerminationStrategy, isActive, isBeingExecuted, isPaused, isProducer, isStateless, onSignal, 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

MultipleInstanceOfFilter

public MultipleInstanceOfFilter()

Method Detail

getOutputPortForType

public <T extends I> OutputPort<T> getOutputPortForType(Class<T> clazz)

onStarting

public void onStarting()

Description copied from class: AbstractStage

Event that is triggered, if all of the following conditions hold:

• after passing the validation phase and
• after the threads are ready-to-run and
• just before the threads execute any stage.

If stage developers want to override this method, they must always call the super implementation first:

 @Override
 protected void onStarting() {
        super.onStarting();
        // insert your code here
 }
 

To throw a checked exception, wrap it to an unchecked exception, e.g. to an IllegalArgumentException.IllegalArgumentException(String, Throwable). Always pass the original exception to the new unchecked exception to allow easy debugging.

Overrides:

onStarting in class AbstractStage

execute

protected void execute(I 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<I>

Parameters:

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