kieker.analysisteetime.plugin.reader.namedRecordPipe

Class PipeReader

java.lang.Object

teetime.framework.AbstractStage

teetime.framework.AbstractProducerStage<IMonitoringRecord>

kieker.analysisteetime.plugin.reader.namedRecordPipe.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 and Description
PipeReader(java.lang.String pipeName) Creates a new instance of this class using the given parameters.

Method Summary

Modifier and Type	Method and 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.
void	terminateStage()

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, toString, workCompleted

Methods inherited from class java.lang.Object

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

Constructor Detail

PipeReader

public PipeReader(java.lang.String pipeName)

Creates a new instance of this class using the given parameters.

Parameters:

configuration - The configuration for this component.

projectContext - The project context for this component.

Method Detail

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

terminateStage

public void terminateStage()

Overrides:

terminateStage in class teetime.framework.AbstractStage