added onInitializing() to Stage

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

@@ -35,6 +35,8 @@ import teetime.framework.validation.InvalidPortConnection;
  * @since 1.1
  * @author Christian Wulf, Nelson Tavares de Sousa
  *
+ * @deprecated This concept is not yet implemented in a correct way. As soon as the concept is stable, we will remove the deprecated tag.
+ *
  */
 @Deprecated
 public abstract class AbstractCompositeStage extends Stage {
@@ -119,6 +121,11 @@ public abstract class AbstractCompositeStage extends Stage {
 		return getFirstStage().getOwningThread();
 	}
 
+	@Override
+	public final void onInitializing() throws Exception {
+		getFirstStage().onInitializing();
+	}
+
 	@Override
 	public final void onValidating(final List<InvalidPortConnection> invalidPortConnections) {
 		getFirstStage().onValidating(invalidPortConnections);

src/main/java/teetime/framework/AbstractStage.java

@@ -87,18 +87,23 @@ public abstract class AbstractStage extends Stage {
 		}
 	}
 
+	@Override
+	public void onInitializing() throws Exception {
+		this.connectUnconnectedOutputPorts();
+		currentState = StageState.INITIALIZED;
+		logger.trace("Initialized.");
+	}
+
 	@Override
 	public void onValidating(final List<InvalidPortConnection> invalidPortConnections) {
 		this.validateOutputPorts(invalidPortConnections);
 		currentState = StageState.VALIDATED;
+		logger.trace("Validated.");
 	}
 
 	@SuppressWarnings("PMD.SignatureDeclareThrowsException")
 	@Override
 	public void onStarting() throws Exception {
-		this.owningThread = Thread.currentThread();
-
-		this.connectUnconnectedOutputPorts();
 		currentState = StageState.STARTED;
 		logger.trace("Started.");
 	}
@@ -183,13 +188,12 @@ public abstract class AbstractStage extends Stage {
 	public void validateOutputPorts(final List<InvalidPortConnection> invalidPortConnections) {
 		for (OutputPort<?> outputPort : outputPorts) {
 			final IPipe pipe = outputPort.getPipe();
-			if (null != pipe) { // if output port is connected with another one
-				final Class<?> sourcePortType = outputPort.getType();
-				final Class<?> targetPortType = pipe.getTargetPort().getType();
-				if (null == sourcePortType || !sourcePortType.equals(targetPortType)) {
-					final InvalidPortConnection invalidPortConnection = new InvalidPortConnection(outputPort, pipe.getTargetPort());
-					invalidPortConnections.add(invalidPortConnection);
-				}
+
+			final Class<?> sourcePortType = outputPort.getType();
+			final Class<?> targetPortType = pipe.getTargetPort().getType();
+			if (null == sourcePortType || !sourcePortType.equals(targetPortType)) {
+				final InvalidPortConnection invalidPortConnection = new InvalidPortConnection(outputPort, pipe.getTargetPort());
+				invalidPortConnections.add(invalidPortConnection);
 			}
 		}
 	}

src/main/java/teetime/framework/Analysis.java

@@ -130,43 +130,56 @@ public final class Analysis<T extends AnalysisConfiguration> implements Uncaught
 		}
 
 		for (Stage stage : threadableStageJobs) {
-			Set<Stage> intraStages = traverseIntraStages(stage);
-			AbstractExceptionListener newListener = factory.createInstance();
-			switch (stage.getTerminationStrategy()) {
+			final Thread thread;
+
+			final TerminationStrategy terminationStrategy = stage.getTerminationStrategy();
+			switch (terminationStrategy) {
 			case BY_SIGNAL: {
 				final RunnableConsumerStage runnable = new RunnableConsumerStage(stage);
-				final Thread thread = createThread(newListener, intraStages, stage, runnable);
+				thread = createThread(runnable, stage.getId());
 				this.consumerThreads.add(thread);
 				break;
 			}
 			case BY_SELF_DECISION: {
 				final RunnableProducerStage runnable = new RunnableProducerStage(stage);
-				final Thread thread = createThread(newListener, intraStages, stage, runnable);
+				thread = createThread(runnable, stage.getId());
 				this.finiteProducerThreads.add(thread);
 				break;
 			}
 			case BY_INTERRUPT: {
 				final RunnableProducerStage runnable = new RunnableProducerStage(stage);
-				final Thread thread = createThread(newListener, intraStages, stage, runnable);
+				thread = createThread(runnable, stage.getId());
 				this.infiniteProducerThreads.add(thread);
 				break;
 			}
 			default:
-				break;
+				throw new IllegalStateException("Unhandled termination strategy: " + terminationStrategy);
 			}
+
+			final Set<Stage> intraStages = traverseIntraStages(stage);
+			final AbstractExceptionListener newListener = factory.createInstance();
+			initializeIntraStages(intraStages, thread, newListener);
 		}
 
 	}
 
-	private Thread createThread(final AbstractExceptionListener newListener, final Set<Stage> intraStages, final Stage stage, final AbstractRunnableStage runnable) {
+	private Thread createThread(final AbstractRunnableStage runnable, final String name) {
 		final Thread thread = new Thread(runnable);
+		thread.setUncaughtExceptionHandler(this);
+		thread.setName(name);
+		return thread;
+	}
+
+	private void initializeIntraStages(final Set<Stage> intraStages, final Thread thread, final AbstractExceptionListener newListener) {
 		for (Stage intraStage : intraStages) {
 			intraStage.setOwningThread(thread);
 			intraStage.setExceptionHandler(newListener);
+			try {
+				intraStage.onInitializing();
+			} catch (Exception e) { // NOPMD(generic framework catch)
+				throw new IllegalStateException("The following exception occurs within initializing the analysis:", e);
+			}
 		}
-		thread.setUncaughtExceptionHandler(this);
-		thread.setName(stage.getId());
-		return thread;
 	}
 
 	/**

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

@@ -128,6 +128,13 @@ public abstract class Stage {
 
 	public abstract void onValidating(List<InvalidPortConnection> invalidPortConnections);
 
+	/**
+	 * Event that is triggered within the initialization phase of the analysis.
+	 * It does not count to the execution time.
+	 */
+	@SuppressWarnings("PMD.SignatureDeclareThrowsException")
+	public abstract void onInitializing() throws Exception;
+
 	@SuppressWarnings("PMD.SignatureDeclareThrowsException")
 	public abstract void onStarting() throws Exception;
 
@@ -137,4 +144,5 @@ public abstract class Stage {
 	protected final void setExceptionHandler(final AbstractExceptionListener exceptionHandler) {
 		this.exceptionHandler = exceptionHandler;
 	}
+
 }

src/main/java/teetime/framework/StageState.java

@@ -17,6 +17,7 @@ package teetime.framework;
 
 public enum StageState {
 
+	INITIALIZED,
 	CREATED,
 	VALIDATING, VALIDATED,
 	STARTING, STARTED,