Package kieker.analysis.generic.source.namedpipe

Class PipeReader

java.lang.Object
teetime.framework.AbstractStage
teetime.framework.AbstractProducerStage<IMonitoringRecord>
kieker.analysis.generic.source.namedpipe.PipeReader
All Implemented Interfaces:
IPipeReader
public class PipeReader extends teetime.framework.AbstractProducerStage<IMonitoringRecord> implements IPipeReader
This reader can be used to read records via an in-memory pipe.
Since:
1.3
Author:
Andre van Hoorn, Lars Bluemke

  • Field Summary

    Fields inherited from class teetime.framework.AbstractProducerStage

    outputPort

    Fields inherited from class teetime.framework.AbstractStage

    logger

  • Constructor Summary

    Constructors
    Constructor
    Description
    PipeReader(String pipeName)
    Creates a new instance of this class using the given parameters.

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    execute()
    Blocks until the associated pipe is being closed.
    boolean
    newMonitoringRecord(IMonitoringRecord rec)
    This method sends a given records directly to the output port.
    void
    notifyPipeClosed()
    Called to notify the reader that the pipe is closed.

    Methods inherited from class teetime.framework.AbstractProducerStage

    getOutputPort, getTerminationStrategy

    Methods inherited from class teetime.framework.AbstractStage

    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

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

  • Constructor Details

    • PipeReader

      public PipeReader(String pipeName)
      Creates a new instance of this class using the given parameters.
      Parameters:
      pipeName - name of the pipe

  • Method Details

    • execute

      protected void execute()
      Blocks until the associated pipe is being closed.
      Specified by:
      execute in class teetime.framework.AbstractStage

    • newMonitoringRecord

      public boolean newMonitoringRecord(IMonitoringRecord rec)
      This method sends a given records directly to the output port.
      Specified by:
      newMonitoringRecord in interface IPipeReader
      Parameters:
      rec - The new record object.
      Returns:
      true if and only if the record has been delivered.

    • notifyPipeClosed

      public void notifyPipeClosed()
      Called to notify the reader that the pipe is closed.
      Specified by:
      notifyPipeClosed in interface IPipeReader