Class ProbeControlStage
java.lang.Object
teetime.framework.AbstractStage
teetime.framework.AbstractConsumerStage<BasicTcpControlEvent>
kieker.analysis.architecture.adaptation.ProbeControlStage
public class ProbeControlStage extends teetime.framework.AbstractConsumerStage<BasicTcpControlEvent>
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
-
Constructor Summary
Constructors Constructor Description ProbeControlStage(IProbeController probeController)
Initiates the filter with a newTcpProbeController
. -
Method Summary
Modifier and Type Method Description protected void
execute(BasicTcpControlEvent 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
-
Constructor Details
-
ProbeControlStage
Initiates the filter with a newTcpProbeController
.- Parameters:
probeController
- corresponding probe controller
-
-
Method Details
-
execute
- Specified by:
execute
in classteetime.framework.AbstractConsumerStage<BasicTcpControlEvent>
-
getOutputPort
-