From a1bad4a7016d137082b414510310c6f75dd04851 Mon Sep 17 00:00:00 2001
From: Christian Wulf <chw@informatik.uni-kiel.de>
Date: Wed, 27 Jul 2016 16:50:31 +0200
Subject: [PATCH] added TcpReaderConfig
---
.../stage/io/network/TcpReaderConfig.java | 23 +++++++++++++++++++
1 file changed, 23 insertions(+)
create mode 100644 src/test/java/teetime/stage/io/network/TcpReaderConfig.java
diff --git a/src/test/java/teetime/stage/io/network/TcpReaderConfig.java b/src/test/java/teetime/stage/io/network/TcpReaderConfig.java
new file mode 100644
index 00000000..5291ca37
--- /dev/null
+++ b/src/test/java/teetime/stage/io/network/TcpReaderConfig.java
@@ -0,0 +1,23 @@
+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();
+ }
+}
--
GitLab