public class ProbeControlStage extends teetime.framework.AbstractConsumerStage<AbstractTcpControlEvent>
control events
, processes them and in case of error
sends the error message to an error sink.Constructor and Description |
---|
ProbeControlStage(IProbeController probeController)
Initiates the filter with a new
TcpProbeController . |
Modifier and Type | Method and Description |
---|---|
protected void |
execute(AbstractTcpControlEvent event) |
teetime.framework.OutputPort<IErrorMessages> |
getOutputPort() |
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, onTerminating, onValidating, removeDynamicPort, removeDynamicPort, setPaused, setStateless, shouldBeTerminated, signalAlreadyReceived, terminateStage, toString, workCompleted
public ProbeControlStage(IProbeController probeController)
TcpProbeController
.probeController
- corresponding probe controllerprotected void execute(AbstractTcpControlEvent event)
execute
in class teetime.framework.AbstractConsumerStage<AbstractTcpControlEvent>
public teetime.framework.OutputPort<IErrorMessages> getOutputPort()
Copyright 2021 Kieker Project, http://kieker-monitoring.net