Merge branch 'Trace-Aggr-Analysis' of...

Merge branch 'Trace-Aggr-Analysis' of gitlab@build.se.informatik.uni-kiel.de:teetime/kieker-teetime-stages.git into Trace-Aggr-Analysis

src/test/java/teetime/stage/io/network/TcpReaderConfig.java

+package teetime.stage.io.network;
+
+import kieker.common.record.IMonitoringRecord;
+
+import teetime.framework.Configuration;
+import teetime.framework.Execution;
+import teetime.stage.io.Printer;
+
+public class TcpReaderConfig extends Configuration {
+
+	public TcpReaderConfig() {
+		TcpReaderStage tcpReaderStage = new TcpReaderStage();
+		Printer<IMonitoringRecord> printer = new Printer<IMonitoringRecord>();
+
+		connectPorts(tcpReaderStage.getOutputPort(), printer.getInputPort());
+	}
+
+	public static void main(final String[] args) {
+		TcpReaderConfig tcpReaderConfig = new TcpReaderConfig();
+		Execution<Configuration> execution = new Execution<Configuration>(tcpReaderConfig);
+		execution.executeBlocking();
+	}
+}

src/test/java/teetime/stage/io/network/TcpReaderStageTest.java

+package teetime.stage.io.network;
+
+import static org.hamcrest.MatcherAssert.assertThat;
+import static org.hamcrest.core.Is.is;
+import static org.hamcrest.core.IsEqual.equalTo;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import org.junit.Ignore;
+import org.junit.Test;
+
+import kieker.common.record.IMonitoringRecord;
+
+import teetime.framework.test.StageTester;
+
+public class TcpReaderStageTest {
+
+	@Test
+	@Ignore
+	public void testNonStringRecordTransmission() throws Exception {
+		List<IMonitoringRecord> receivedRecords = new ArrayList<IMonitoringRecord>();
+
+		TcpReaderStage stage = new TcpReaderStage();
+		StageTester.test(stage).and()
+				.receive(receivedRecords).from(stage.getOutputPort())
+				.start();
+
+		List<IMonitoringRecord> sentRecords = new ArrayList<IMonitoringRecord>();
+		// TODO
+
+		assertThat(receivedRecords, is(equalTo(sentRecords)));
+	}
+}