kieker.analysis.source.time

Class TimeSourceStage

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractProducerStage<java.lang.Long>

kieker.analysis.source.time.TimeSourceStage

public class TimeSourceStage
extends teetime.framework.AbstractProducerStage<java.lang.Long>

This plugin provides the current (system) time in regular intervals. The time is delivered to the two output ports as both a timestamp and a TimestampRecord instance.

The reader can be configured to emit an arbitrary amount of signals. It can also be configured to emit an infinite amount of signals.

The sent timestamps are created using System.nanoTime() as a time source, which is being converted to the global time unit (as defined in the configuration from the given IProjectContext).

Since:

1.15

Author:

Reiner Jung

Field Summary

Fields inherited from class teetime.framework.AbstractProducerStage

outputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
TimeSourceStage(long delay, java.lang.Long numberOfImpulses)

Method Summary

Modifier and Type	Method and Description
protected void	execute()

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

TimeSourceStage

public TimeSourceStage(long delay,
                       java.lang.Long numberOfImpulses)

Method Detail

execute

protected void execute()
                throws java.lang.Exception

Specified by:

execute in class teetime.framework.AbstractStage

Throws:

java.lang.Exception