diff --git a/src/main/java/teetime/framework/OutputPort.java b/src/main/java/teetime/framework/OutputPort.java index beea4479857fe6c3aff579281a942df1fc13a355..4d23baaad7a2030dd3bbe361f8161b8bb63dca65 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 0000000000000000000000000000000000000000..fe7abe06fe363a8a8734a8b74c9cc0b497a4acee --- /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 b17a05f640444952762360a6eb16dddbe52fab56..ffedd94cccba84a7db86c0809cbd13f1c2a718c6 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 649ce682a988e26f70efd79c3f64e0125d98dfd9..7ab0de1a9ddddcbc0414e4b4050a38bb0a19b4f1 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());