removed endStage from TCPReaderSink

src/main/java/teetime/variant/methodcallWithPorts/stage/EndStage.java

 package teetime.variant.methodcallWithPorts.stage;
 
-import java.util.LinkedList;
-import java.util.List;
 import java.util.UUID;
 
 import teetime.util.ConstructorClosure;
@@ -14,9 +12,9 @@ public class EndStage<T> implements StageWithPort<T, T> {
 
 	private final InputPort<T> inputPort = new InputPort<T>(this);
 
-	public int count;
+	// public int count;
 	public ConstructorClosure<?> closure;
-	public List<Object> list = new LinkedList<Object>();
+	// public List<Object> list = new LinkedList<Object>();
 
 	private final String id;
 
@@ -31,13 +29,12 @@ public class EndStage<T> implements StageWithPort<T, T> {
 
 	@Override
 	public StageWithPort<?, ?> getParentStage() {
-		// TODO Auto-generated method stub
 		return null;
 	}
 
 	@Override
 	public void setParentStage(final StageWithPort<?, ?> parentStage, final int index) {
-		// TODO Auto-generated method stub
+		// do nothing
 
 	}
 
@@ -53,7 +50,6 @@ public class EndStage<T> implements StageWithPort<T, T> {
 
 	@Override
 	public OutputPort<T> getOutputPort() {
-		// TODO Auto-generated method stub
 		return null;
 	}
 
@@ -68,8 +64,7 @@ public class EndStage<T> implements StageWithPort<T, T> {
 
 	@Override
 	public void onStart() {
-		// TODO Auto-generated method stub
-
+		// do nothing
 	}
 
 	@Override

src/test/java/teetime/variant/methodcallWithPorts/examples/kiekerdays/TCPReaderSink.java

@@ -45,7 +45,6 @@ public class TCPReaderSink extends ProducerStage<Void, IMonitoringRecord> {
 
 	private static final int MESSAGE_BUFFER_SIZE = 65535;
 
-	// BETTER use a non thread-safe implementation to increase performance. A thread-safe version is not necessary.
 	private final ILookup<String> stringRegistry = new Lookup<String>();
 	private int port1 = 10133;
 	private int port2 = 10134;

src/test/java/teetime/variant/methodcallWithPorts/examples/kiekerdays/TcpTraceLogging.java

 package teetime.variant.methodcallWithPorts.examples.kiekerdays;
 
 import teetime.variant.explicitScheduling.framework.core.Analysis;
-import teetime.variant.methodcallWithPorts.framework.core.Pipeline;
 import teetime.variant.methodcallWithPorts.framework.core.RunnableStage;
 import teetime.variant.methodcallWithPorts.framework.core.StageWithPort;
-import teetime.variant.methodcallWithPorts.framework.core.pipe.SingleElementPipe;
-import teetime.variant.methodcallWithPorts.stage.EndStage;
 
 import kieker.common.record.IMonitoringRecord;
 
@@ -35,15 +32,15 @@ public class TcpTraceLogging extends Analysis {
 
 	private StageWithPort<Void, IMonitoringRecord> buildTcpPipeline() {
 		TCPReaderSink tcpReader = new TCPReaderSink();
-		EndStage<IMonitoringRecord> endStage = new EndStage<IMonitoringRecord>();
-
-		SingleElementPipe.connect(tcpReader.getOutputPort(), endStage.getInputPort());
-
-		// create and configure pipeline
-		Pipeline<Void, IMonitoringRecord> pipeline = new Pipeline<Void, IMonitoringRecord>();
-		pipeline.setFirstStage(tcpReader);
-		pipeline.setLastStage(endStage);
-		return pipeline;
+		// EndStage<IMonitoringRecord> endStage = new EndStage<IMonitoringRecord>();
+		//
+		// SingleElementPipe.connect(tcpReader.getOutputPort(), endStage.getInputPort());
+		//
+		// // create and configure pipeline
+		// Pipeline<Void, IMonitoringRecord> pipeline = new Pipeline<Void, IMonitoringRecord>();
+		// pipeline.setFirstStage(tcpReader);
+		// pipeline.setLastStage(endStage);
+		return tcpReader;
 	}
 
 	public static void main(final String[] args) {