As there is no mechanism indicating a potential loss of data, this test

can't be modified to always run perfectly

src/main/java/teetime/framework/RunnableConsumerStage.java

@@ -81,7 +81,7 @@ final class RunnableConsumerStage extends AbstractRunnableStage {
 		logger.debug("Checking signals for: " + Arrays.toString(inputPorts));
 		for (InputPort<?> inputPort : inputPorts) {
 			IPipe pipe = inputPort.getPipe();
-			if (pipe instanceof AbstractInterThreadPipe) {
+			if (pipe instanceof AbstractInterThreadPipe) { // TODO: is this needed?
 				AbstractInterThreadPipe intraThreadPipe = (AbstractInterThreadPipe) pipe;
 				ISignal signal = intraThreadPipe.getSignal();
 				if (null != signal) {

src/main/java/teetime/stage/basic/merger/Merger.java

@@ -77,7 +77,7 @@ public final class Merger<T> extends AbstractStage {
 	@SuppressWarnings("unchecked")
 	@Override
 	public void onSignal(final ISignal signal, final InputPort<?> inputPort) {
-		this.logger.debug("Got signal: " + signal + " from input port: " + inputPort);
+		this.logger.warn("Got signal: " + signal + " from input port: " + inputPort);
 
 		Class<? extends ISignal> signalClass = signal.getClass();
 
@@ -94,7 +94,6 @@ public final class Merger<T> extends AbstractStage {
 		}
 
 		if (signalMap.get(signalClass).size() == this.getInputPorts().length) {
-			System.out.println("SENT");
 			signal.trigger(this);
 			this.outputPort.sendSignal(signal);
 			signalMap.remove(signalClass);