Package kieker.analysis.generic

Class RealtimeRecordDelayConsumer

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractConsumerStage<IMonitoringRecord>

kieker.analysis.generic.RealtimeRecordDelayConsumer

public class RealtimeRecordDelayConsumer
extends teetime.framework.AbstractConsumerStage<IMonitoringRecord>

Receives records at the input port and stores them in a queue for the RealtimeRecordDelayProducer.

Since:

1.13

Author:

Lars Bluemke

Field Summary

Fields inherited from class teetime.framework.AbstractConsumerStage

inputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor	Description
RealtimeRecordDelayConsumer(LinkedBlockingQueue<Object> recordQueue, Object endToken)	Creates a new instance of this class using the given parameters.

Method Summary

Modifier and Type	Method	Description
protected void	execute(IMonitoringRecord monitoringRecord)
protected void	onTerminating()

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

RealtimeRecordDelayConsumer

public RealtimeRecordDelayConsumer(LinkedBlockingQueue<Object> recordQueue,
 Object endToken)

Creates a new instance of this class using the given parameters.

Parameters:

recordQueue - Queue to pass records from RealtimeRecordDelayConsumer to RealtimeRecordDelayProducer.

endToken - Simple Object to indicate that no more records are received and the stage can terminate.

Method Details

execute

protected void execute(IMonitoringRecord monitoringRecord)

Specified by:

execute in class teetime.framework.AbstractConsumerStage<IMonitoringRecord>

onTerminating

protected void onTerminating()

Overrides:

onTerminating in class teetime.framework.AbstractStage