public class RealtimeRecordDelayProducer extends teetime.framework.AbstractProducerStage<IMonitoringRecord>
AbstractProducerStage
it
is always declared as active.Modifier and Type | Field and Description |
---|---|
static double |
ACCELERATION_FACTOR_DEFAULT |
Constructor and Description |
---|
RealtimeRecordDelayProducer(java.util.concurrent.LinkedBlockingQueue<java.lang.Object> recordQueue,
java.lang.Object endToken,
java.util.concurrent.TimeUnit timeunit,
double accelerationFactor)
Creates a new instance of this class using the given parameters.
|
Modifier and Type | Method and Description |
---|---|
protected void |
execute() |
long |
getNegativeDelayWarningBound()
Returns the time bound for which a warning is displayed when the computed delay falls below -(time bound).
|
void |
setNegativeDelayWarningBound(long negativeDelay,
java.util.concurrent.TimeUnit unit)
Sets the time bound for which a warning is displayed when the computed delay falls below -(time bound).
|
getOutputPort, getTerminationStrategy
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
public static final double ACCELERATION_FACTOR_DEFAULT
public RealtimeRecordDelayProducer(java.util.concurrent.LinkedBlockingQueue<java.lang.Object> recordQueue, java.lang.Object endToken, java.util.concurrent.TimeUnit timeunit, double accelerationFactor)
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.timeunit
- The time unit to be used.accelerationFactor
- Determines the replay speed.protected void execute()
execute
in class teetime.framework.AbstractStage
public long getNegativeDelayWarningBound()
public void setNegativeDelayWarningBound(long negativeDelay, java.util.concurrent.TimeUnit unit)
negativeDelay
- The chosen time bound.unit
- Time unit of the chosen time bound.Copyright 2020 Kieker Project, http://kieker-monitoring.net