diff --git a/src/main/java/teetime/framework/RunnableConsumerStage.java b/src/main/java/teetime/framework/RunnableConsumerStage.java index 1def6debf106b609bdd40cbb4bd003ed9fb12301..95d6db1701c684cd29447cc31fde5fd23cfeef61 100644 --- a/src/main/java/teetime/framework/RunnableConsumerStage.java +++ b/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) { diff --git a/src/main/java/teetime/stage/basic/merger/Merger.java b/src/main/java/teetime/stage/basic/merger/Merger.java index 706fe08aed95f0e0dcc73a16a3992b2b1531d4ba..739574e8787bb3dbdefd5a3879240330fe788f1b 100644 --- a/src/main/java/teetime/stage/basic/merger/Merger.java +++ b/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);