kieker.analysisteetime.plugin.filter.forward

Class CountingFilter

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractConsumerStage<java.lang.Object>

kieker.analysisteetime.plugin.filter.forward.CountingFilter

public final class CountingFilter
extends teetime.framework.AbstractConsumerStage<java.lang.Object>

An instance of this class receives any objects, increments an intern thread-safe counter without printing any message and delivers the unchanged objects to the output. The value of the counter can be retrieved by connected to the respective output port using a corresponding method.

Since:

1.4

Author:

Jan Waller, Nils Christian Ehmke, Lars Bluemke

Field Summary

Fields inherited from class teetime.framework.AbstractConsumerStage

inputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
CountingFilter() Creates a new instance of this class and sets the time stamp of initialization.

Method Summary

Modifier and Type	Method and Description
protected void	execute(java.lang.Object event) This method represents the input port of this filter.
long	getMessageCount() Returns the number of objects received until now.
PlainText	plainTextDisplay()
XYPlot	xyPlotDisplay()

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

CountingFilter

public CountingFilter()

Creates a new instance of this class and sets the time stamp of initialization.

Method Detail

getMessageCount

public final long getMessageCount()

Returns the number of objects received until now.

Returns:

The current counter value.

execute

protected void execute(java.lang.Object event)

This method represents the input port of this filter.

Specified by:

execute in class teetime.framework.AbstractConsumerStage<java.lang.Object>

Parameters:

event - The next event.

plainTextDisplay

public final PlainText plainTextDisplay()

xyPlotDisplay

public final XYPlot xyPlotDisplay()