added a draft for a traversor

src/main/java/teetime/framework/AbstractCompositeStage.java

@@ -15,6 +15,8 @@
  */
 package teetime.framework;
 
+import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.Collection;
 import java.util.List;
 
@@ -32,16 +34,24 @@ import teetime.framework.validation.InvalidPortConnection;
  * @author Christian Wulf, Nelson Tavares de Sousa
  *
  */
-@SuppressWarnings("PMD.AbstractNaming")
 public abstract class AbstractCompositeStage extends Stage {
 
 	private static final IPipeFactory INTRA_PIPE_FACTORY = PipeFactoryRegistry.INSTANCE
 			.getPipeFactory(ThreadCommunication.INTRA, PipeOrdering.ARBITRARY, false);
 
+	private final List<OutputPort<?>> outputPorts;
+
 	protected abstract Stage getFirstStage();
 
 	protected abstract Collection<? extends Stage> getLastStages();
 
+	public AbstractCompositeStage() {
+		outputPorts = new ArrayList<OutputPort<?>>();
+		for (final Stage s : getLastStages()) {
+			outputPorts.addAll(Arrays.asList(s.getOutputPorts()));
+		}
+	}
+
 	@Override
 	protected final void executeStage() {
 		getFirstStage().executeStage();
@@ -72,6 +82,11 @@ public abstract class AbstractCompositeStage extends Stage {
 		return getFirstStage().getInputPorts();
 	}
 
+	@Override
+	protected OutputPort<?>[] getOutputPorts() {
+		return outputPorts.toArray(new OutputPort[0]);
+	}
+
 	@Override
 	public final StageState getCurrentState() {
 		return getFirstStage().getCurrentState();

src/main/java/teetime/framework/Stage.java

@@ -119,6 +119,8 @@ public abstract class Stage {
 
 	protected abstract InputPort<?>[] getInputPorts();
 
+	protected abstract OutputPort<?>[] getOutputPorts();
+
 	// events
 
 	public abstract void onValidating(List<InvalidPortConnection> invalidPortConnections);

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

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

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

+package teetime.framework;
+
+import teetime.framework.StageVisitor.VisitorBehavior;
+import teetime.framework.pipe.IPipe;
+
+public class Traversor {
+
+	private final StageVisitor stageVisitor;
+
+	public Traversor(final StageVisitor stageVisitor) {
+		this.stageVisitor = stageVisitor;
+	}
+
+	public void traverse(final Stage stage) {
+		VisitorBehavior visitorBehavior = stageVisitor.visit(stage);
+		if (visitorBehavior == VisitorBehavior.STOP) {
+			return;
+		}
+
+		OutputPort<?>[] outputPorts = stage.getOutputPorts();
+		for (OutputPort<?> outputPort : outputPorts) {
+			IPipe pipe = outputPort.getPipe();
+			if (null != pipe) {
+				Stage owningStage = pipe.getTargetPort().getOwningStage();
+				traverse(owningStage); // recursive call
+			}
+		}
+	}
+}

wiki @ 0e447457

-Subproject commit 162510ff4d2f04011498ba6920aae0c78347c6c8
+Subproject commit 0e4474577e1f49bc96e734c286b2d9e0363895e8