Skip to content
Snippets Groups Projects
Commit 2d0d9d80 authored by Lars Erik Blümke's avatar Lars Erik Blümke
Browse files

restructured AbstarctReader to an AbstarctStage for more flexibility

parent ccc29ce1
No related branches found
No related tags found
No related merge requests found
......@@ -17,9 +17,8 @@
package kieker.analysis.plugin.reader;
import kieker.analysis.plugin.annotation.Plugin;
import kieker.common.record.IMonitoringRecord;
import teetime.framework.AbstractProducerStage;
import teetime.framework.AbstractStage;
/**
* This abstract class defines the basic structure of each reader. Each reader has its reader logic separated
......@@ -28,7 +27,7 @@ import teetime.framework.AbstractProducerStage;
* @author Lars Erik Bluemke
*/
@Plugin
public abstract class AbstractReader extends AbstractProducerStage<IMonitoringRecord> {
public abstract class AbstractReader extends AbstractStage {
protected IReaderLogic readerLogic;
......@@ -37,11 +36,6 @@ public abstract class AbstractReader extends AbstractProducerStage<IMonitoringRe
readerLogic.read();
}
/** Called from reader logic to send the read records to the output port */
public void deliverRecord(final IMonitoringRecord monitoringRecord) {
this.getOutputPort().send(monitoringRecord);
}
/** Terminates the reader logic by returning from read method. */
public void terminate(final boolean error) {
readerLogic.terminate(error);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment