worked on draft for Traversor

src/main/java/teetime/framework/StageVisitor.java

 package teetime.framework;
 
+import teetime.framework.pipe.IPipe;
+
 public interface StageVisitor {
 
 	public enum VisitorBehavior {
 		CONTINUE, STOP
 	}
 
-	VisitorBehavior visit(Stage stage);
+	VisitorBehavior visit(Stage stage, IPipe inputPipe);
 
 }

src/main/java/teetime/framework/Traversor.java

 package teetime.framework;
 
+import java.util.HashSet;
+import java.util.Set;
+
 import teetime.framework.StageVisitor.VisitorBehavior;
 import teetime.framework.pipe.IPipe;
 
 public class Traversor {
 
 	private final StageVisitor stageVisitor;
+	private final Set<Stage> visitedStage = new HashSet<Stage>();
 
 	public Traversor(final StageVisitor stageVisitor) {
 		this.stageVisitor = stageVisitor;
 	}
 
-	public void traverse(final Stage stage) {
-		VisitorBehavior visitorBehavior = stageVisitor.visit(stage);
+	public void traverse(final Stage stage, final IPipe inputPipe) {
+		if (!visitedStage.contains(stage)) {
+			visitedStage.add(stage);
+		} else {
+			return;
+		}
+
+		VisitorBehavior visitorBehavior = stageVisitor.visit(stage, inputPipe);
 		if (visitorBehavior == VisitorBehavior.STOP) {
 			return;
 		}
@@ -22,7 +32,7 @@ public class Traversor {
 			IPipe pipe = outputPort.getPipe();
 			if (null != pipe) {
 				Stage owningStage = pipe.getTargetPort().getOwningStage();
-				traverse(owningStage); // recursive call
+				traverse(owningStage, pipe); // recursive call
 			}
 		}
 	}