moved logic back to A3

src/main/java/teetime/framework/A1ThreadableStageCollector.java

@@ -19,6 +19,7 @@ import java.util.HashSet;
 import java.util.Set;
 
 import teetime.framework.Traverser.VisitorBehavior;
+import teetime.framework.pipe.DummyPipe;
 
 /**
  * Searches for threadable stages
@@ -44,4 +45,10 @@ class A1ThreadableStageCollector implements ITraverserVisitor {
 		return VisitorBehavior.CONTINUE;
 	}
 
+	@Override
+	public void visit(final DummyPipe pipe, final AbstractPort<?> port) {
+		// TODO Auto-generated method stub
+
+	}
+
 }

src/main/java/teetime/framework/A2InvalidThreadAssignmentCheck.java

@@ -21,6 +21,7 @@ import com.carrotsearch.hppc.ObjectIntHashMap;
 import com.carrotsearch.hppc.ObjectIntMap;
 
 import teetime.framework.Traverser.VisitorBehavior;
+import teetime.framework.pipe.DummyPipe;
 import teetime.framework.pipe.IPipe;
 
 /**
@@ -90,5 +91,11 @@ public class A2InvalidThreadAssignmentCheck {
 			return VisitorBehavior.STOP;
 		}
 
+		@Override
+		public void visit(final DummyPipe pipe, final AbstractPort<?> port) {
+			// TODO Auto-generated method stub
+
+		}
+
 	}
 }

src/main/java/teetime/framework/A3PipeInstantiation.java

@@ -18,7 +18,11 @@ package teetime.framework;
 import java.util.HashSet;
 import java.util.Set;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 import teetime.framework.Traverser.VisitorBehavior;
+import teetime.framework.pipe.DummyPipe;
 import teetime.framework.pipe.IPipe;
 import teetime.framework.pipe.IPipeFactory;
 import teetime.framework.pipe.InstantiationPipe;
@@ -31,6 +35,7 @@ import teetime.framework.pipe.UnboundedSpScPipeFactory;
  */
 class A3PipeInstantiation implements ITraverserVisitor {
 
+	private static final Logger LOGGER = LoggerFactory.getLogger(Execution.class);
 	private static final IPipeFactory interBoundedThreadPipeFactory = new SpScPipeFactory();
 	private static final IPipeFactory interUnboundedThreadPipeFactory = new UnboundedSpScPipeFactory();
 	private static final IPipeFactory intraThreadPipeFactory = new SingleElementPipeFactory();
@@ -77,4 +82,9 @@ class A3PipeInstantiation implements ITraverserVisitor {
 
 	}
 
+	@Override
+	public void visit(final DummyPipe pipe, final AbstractPort<?> port) {
+		LOGGER.debug("Unconnected port " + port + " in stage " + port.getOwningStage().getId());
+	}
+
 }

src/main/java/teetime/framework/ITraverserVisitor.java

@@ -16,6 +16,7 @@
 package teetime.framework;
 
 import teetime.framework.Traverser.VisitorBehavior;
+import teetime.framework.pipe.DummyPipe;
 
 public interface ITraverserVisitor {
 
@@ -23,4 +24,6 @@ public interface ITraverserVisitor {
 
 	VisitorBehavior visit(AbstractPort<?> port);
 
+	void visit(DummyPipe pipe, AbstractPort<?> port);
+
 }

src/main/java/teetime/framework/IntraStageCollector.java

@@ -16,6 +16,7 @@
 package teetime.framework;
 
 import teetime.framework.Traverser.VisitorBehavior;
+import teetime.framework.pipe.DummyPipe;
 
 public class IntraStageCollector implements ITraverserVisitor {
 
@@ -40,4 +41,10 @@ public class IntraStageCollector implements ITraverserVisitor {
 		return VisitorBehavior.CONTINUE;
 	}
 
+	@Override
+	public void visit(final DummyPipe pipe, final AbstractPort<?> port) {
+		// TODO Auto-generated method stub
+
+	}
+
 }

src/main/java/teetime/framework/Traverser.java

@@ -18,9 +18,6 @@ package teetime.framework;
 import java.util.HashSet;
 import java.util.Set;
 
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
 import teetime.framework.pipe.DummyPipe;
 
 /**
@@ -32,8 +29,6 @@ import teetime.framework.pipe.DummyPipe;
  */
 public class Traverser {
 
-	private static final Logger LOGGER = LoggerFactory.getLogger(Execution.class);
-
 	public static enum Direction {
 		BACKWARD(1), FORWARD(2), BOTH(BACKWARD.value | FORWARD.value);
 
@@ -87,11 +82,7 @@ public class Traverser {
 
 	private void visitAndTraverse(final AbstractPort<?> port, final Direction direction) {
 		if (port.getPipe() instanceof DummyPipe) {
-			if (direction == Direction.FORWARD) {
-				if (traverserVisitor instanceof A3PipeInstantiation) {
-					LOGGER.debug("Unconnected port " + port + " in stage " + port.getOwningStage().getId());
-				}
-			}
+			traverserVisitor.visit((DummyPipe) port.getPipe(), port);
 			return;
 		}
 		VisitorBehavior behavior = traverserVisitor.visit(port);