From 360d2dc0c9ce8d31fc4f32262ca36893c6f9a802 Mon Sep 17 00:00:00 2001
From: Nelson Tavares de Sousa <stu103017@mail.uni-kiel.de>
Date: Wed, 6 May 2015 14:03:46 +0200
Subject: [PATCH] added test
---
.../io/filesystem/Dir2RecordsFilterTest.java | 59 +++++++++++++++++++
1 file changed, 59 insertions(+)
create mode 100644 src/test/java/teetime/stage/io/filesystem/Dir2RecordsFilterTest.java
diff --git a/src/test/java/teetime/stage/io/filesystem/Dir2RecordsFilterTest.java b/src/test/java/teetime/stage/io/filesystem/Dir2RecordsFilterTest.java
new file mode 100644
index 00000000..9b9f5c2a
--- /dev/null
+++ b/src/test/java/teetime/stage/io/filesystem/Dir2RecordsFilterTest.java
@@ -0,0 +1,59 @@
+package teetime.stage.io.filesystem;
+
+import java.io.File;
+
+import org.junit.Test;
+
+import teetime.framework.AbstractCompositeStage;
+import teetime.framework.Analysis;
+import teetime.framework.AnalysisConfiguration;
+import teetime.framework.OutputPort;
+import teetime.framework.Stage;
+import teetime.stage.InitialElementProducer;
+import teetime.stage.className.ClassNameRegistryRepository;
+import teetime.stage.io.Printer;
+
+import kieker.common.record.IMonitoringRecord;
+
+public class Dir2RecordsFilterTest {
+
+ class TestConfiguration extends AnalysisConfiguration {
+
+ public TestConfiguration() {
+ final ReadingComposite reader = new ReadingComposite(new File("."));
+ final Printer<IMonitoringRecord> printer = new Printer<IMonitoringRecord>();
+
+ super.connectIntraThreads(reader.getOutputPort(), printer.getInputPort());
+ super.addThreadableStage(reader);
+ }
+ }
+
+ @SuppressWarnings("deprecation")
+ class ReadingComposite extends AbstractCompositeStage {
+
+ private final InitialElementProducer<File> producer;
+ private final Dir2RecordsFilter reader;
+
+ public ReadingComposite(final File importDirectory) {
+ this.producer = new InitialElementProducer<File>(importDirectory);
+ this.reader = new Dir2RecordsFilter(new ClassNameRegistryRepository());
+
+ super.connectPorts(this.producer.getOutputPort(), this.reader.getInputPort());
+ }
+
+ public OutputPort<IMonitoringRecord> getOutputPort() {
+ return this.reader.getOutputPort();
+ }
+
+ @Override
+ protected Stage getFirstStage() {
+ return this.producer;
+ }
+
+ }
+
+ @Test
+ public void noExceptionThrown() {
+ new Analysis<TestConfiguration>(new TestConfiguration()).executeBlocking();
+ }
+}
--
GitLab