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 0000000000000000000000000000000000000000..5291ca3775a994b35f951efd34f445a4502e9db3 --- /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(); + } +}