teetime.stage

Class InstanceOfFilter<I,O extends I>

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractConsumerStage<I>

teetime.stage.InstanceOfFilter<I,O>

public final class InstanceOfFilter<I,O extends I>
extends AbstractConsumerStage<I>

Author:

Jan Waller, Nils Christian Ehmke, Christian Wulf, Nelson Tavares de Sousa

Field Summary

Fields inherited from class teetime.framework.AbstractConsumerStage

inputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
InstanceOfFilter(Class<O> type)

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.
OutputPort<O>	getMatchedOutputPort()
OutputPort<I>	getMismatchedOutputPort()
OutputPort<O>	getOutputPort() Deprecated. Since 1.1. Use getMatchedOutputPort() instead.
Class<O>	getType()
void	setType(Class<O> type)

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, 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

InstanceOfFilter

public InstanceOfFilter(Class<O> type)

Method Detail

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

getType

public Class<O> getType()

setType

public void setType(Class<O> type)

getOutputPort

@Deprecated
public OutputPort<O> getOutputPort()

Deprecated. Since 1.1. Use getMatchedOutputPort() instead.

Returns:

the output port that is used when the element is a (sub)type of the internal type attribute

getMatchedOutputPort

public OutputPort<O> getMatchedOutputPort()

getMismatchedOutputPort

public OutputPort<I> getMismatchedOutputPort()