kieker.analysis.stage.adaptation

Class ProbeControlStage

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractConsumerStage<AbstractTcpControlEvent>

kieker.analysis.stage.adaptation.ProbeControlStage

public class ProbeControlStage
extends teetime.framework.AbstractConsumerStage<AbstractTcpControlEvent>

Receives control events, processes them and in case of error sends the error message to an error sink.

Since:

1.15

Author:

Marc Adolf

Field Summary

Fields inherited from class teetime.framework.AbstractConsumerStage

inputPort

Fields inherited from class teetime.framework.AbstractStage

logger

Constructor Summary

Constructors

Constructor and Description
ProbeControlStage(IProbeController probeController) Initiates the filter with a new TcpProbeController.

Method Summary

Modifier and Type	Method and Description
protected void	execute(AbstractTcpControlEvent event)
teetime.framework.OutputPort<IErrorMessages>	getOutputPort()

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

ProbeControlStage

public ProbeControlStage(IProbeController probeController)

Initiates the filter with a new TcpProbeController.

Parameters:

probeController - corresponding probe controller

Method Detail

execute

protected void execute(AbstractTcpControlEvent event)

Specified by:

execute in class teetime.framework.AbstractConsumerStage<AbstractTcpControlEvent>

getOutputPort

public teetime.framework.OutputPort<IErrorMessages> getOutputPort()