From bb439888e6c6a8d5ea663f655d0855a52ac246cb Mon Sep 17 00:00:00 2001
From: Christian Wulf <chw@informatik.uni-kiel.de>
Date: Sat, 9 May 2015 23:28:43 +0200
Subject: [PATCH] added AbstractSignal
---
.../java/teetime/framework/OutputPort.java | 1 +
.../framework/signal/AbstractSignal.java | 23 +++++++++++++++++++
src/main/resources/logback.xml | 2 ++
.../stage/basic/merger/MergerTest.java | 5 ++--
4 files changed, 29 insertions(+), 2 deletions(-)
create mode 100644 src/main/java/teetime/framework/signal/AbstractSignal.java
diff --git a/src/main/java/teetime/framework/OutputPort.java b/src/main/java/teetime/framework/OutputPort.java
index beea4479..4d23baaa 100644
--- a/src/main/java/teetime/framework/OutputPort.java
+++ b/src/main/java/teetime/framework/OutputPort.java
@@ -69,4 +69,5 @@ public final class OutputPort<T> extends AbstractPort<T> {
}
pipe.sendSignal(signal);
}
+
}
diff --git a/src/main/java/teetime/framework/signal/AbstractSignal.java b/src/main/java/teetime/framework/signal/AbstractSignal.java
new file mode 100644
index 00000000..fe7abe06
--- /dev/null
+++ b/src/main/java/teetime/framework/signal/AbstractSignal.java
@@ -0,0 +1,23 @@
+package teetime.framework.signal;
+
+import java.util.LinkedList;
+import java.util.List;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+abstract class AbstractSignal implements ISignal {
+
+ protected static final Logger LOGGER = LoggerFactory.getLogger(AbstractSignal.class);
+
+ protected final List<Exception> catchedExceptions = new LinkedList<Exception>();
+
+ protected AbstractSignal() {
+ super();
+ }
+
+ public List<Exception> getCatchedExceptions() {
+ return this.catchedExceptions;
+ }
+
+}
diff --git a/src/main/resources/logback.xml b/src/main/resources/logback.xml
index b17a05f6..ffedd94c 100644
--- a/src/main/resources/logback.xml
+++ b/src/main/resources/logback.xml
@@ -20,6 +20,8 @@
</encoder>
</appender>
+<!-- <logger name="teetime.framework" level="TRACE" /> -->
+
<logger name="util.TimingsReader" level="TRACE">
<appender-ref ref="FILE" />
</logger>
diff --git a/src/test/java/teetime/stage/basic/merger/MergerTest.java b/src/test/java/teetime/stage/basic/merger/MergerTest.java
index 649ce682..7ab0de1a 100644
--- a/src/test/java/teetime/stage/basic/merger/MergerTest.java
+++ b/src/test/java/teetime/stage/basic/merger/MergerTest.java
@@ -58,11 +58,12 @@ public class MergerTest {
pipeFactory.create(this.sndProducer.getOutputPort(), this.mergerUnderTest.getNewInputPort());
pipeFactory.create(this.mergerUnderTest.getOutputPort(), this.collector.getInputPort());
- mergerUnderTest.onStarting();
+ // mergerUnderTest.onInitializing();
+ // mergerUnderTest.onStarting();
}
@Test
- @Ignore
+ // @Ignore
public void roundRobinShouldWork() {
mergerUnderTest.setStrategy(new RoundRobinStrategy());
--
GitLab