Skip to content
Snippets Groups Projects
Commit bb439888 authored by Christian Wulf's avatar Christian Wulf
Browse files

added AbstractSignal

parent 918a8fbb
Branches
Tags
No related merge requests found
......@@ -69,4 +69,5 @@ public final class OutputPort<T> extends AbstractPort<T> {
}
pipe.sendSignal(signal);
}
}
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;
}
}
......@@ -20,6 +20,8 @@
</encoder>
</appender>
<!-- <logger name="teetime.framework" level="TRACE" /> -->
<logger name="util.TimingsReader" level="TRACE">
<appender-ref ref="FILE" />
</logger>
......
......@@ -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());
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment