public class RealtimeRecordDelayConsumer extends teetime.framework.AbstractConsumerStage<IMonitoringRecord>
RealtimeRecordDelayProducer
.Constructor and Description |
---|
RealtimeRecordDelayConsumer(java.util.concurrent.LinkedBlockingQueue<java.lang.Object> recordQueue,
java.lang.Object endToken)
Creates a new instance of this class using the given parameters.
|
Modifier and Type | Method and Description |
---|---|
protected void |
execute(IMonitoringRecord monitoringRecord) |
protected void |
onTerminating() |
createInputPort, execute, getInputPort
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
public RealtimeRecordDelayConsumer(java.util.concurrent.LinkedBlockingQueue<java.lang.Object> recordQueue, java.lang.Object endToken)
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.protected void execute(IMonitoringRecord monitoringRecord)
execute
in class teetime.framework.AbstractConsumerStage<IMonitoringRecord>
protected void onTerminating()
onTerminating
in class teetime.framework.AbstractStage
Copyright 2020 Kieker Project, http://kieker-monitoring.net