diff --git a/src/main/java/teetime/stage/basic/merger/Merger.java b/src/main/java/teetime/stage/basic/merger/Merger.java index ee53d9a80549a09dc490f70c50f1540e8ddeb7e5..706fe08aed95f0e0dcc73a16a3992b2b1531d4ba 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.info("Got signal: " + signal + " from input port: " + inputPort); + this.logger.debug("Got signal: " + signal + " from input port: " + inputPort); Class<? extends ISignal> signalClass = signal.getClass(); @@ -94,6 +94,7 @@ 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);