moved related classes to own package; first prototype

src/main/java/teetime/framework/AbstractConsumerStage.java

 package teetime.framework;
 
+import teetime.framework.exceptionHandling.StageException;
 import teetime.framework.idle.IdleStrategy;
 import teetime.framework.idle.YieldStrategy;
 
@@ -20,7 +21,11 @@ public abstract class AbstractConsumerStage<I> extends AbstractStage {
 			returnNoElement();
 		}
 
-		this.execute(element);
+		try {
+			this.execute(element);
+		} catch (Exception e) {
+			throw new StageException(e, this);
+		}
 	}
 
 	protected abstract void execute(I element);

src/main/java/teetime/framework/AbstractProducerStage.java

 package teetime.framework;
 
+import teetime.framework.exceptionHandling.StageException;
+
 /**
  * The <code>ProducerStage</code> produces at least one element at each execution.<br>
  *
@@ -19,7 +21,11 @@ public abstract class AbstractProducerStage<O> extends AbstractStage {
 
 	@Override
 	public void executeWithPorts() {
-		this.execute();
+		try {
+			this.execute();
+		} catch (Exception e) {
+			throw new StageException(e, this);
+		}
 	}
 
 	@Override

src/main/java/teetime/framework/RunnableStage.java

@@ -3,6 +3,8 @@ package teetime.framework;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import teetime.framework.exceptionHandling.StageException;
+
 abstract class RunnableStage implements Runnable {
 
 	protected final Stage stage;
@@ -22,7 +24,11 @@ abstract class RunnableStage implements Runnable {
 			beforeStageExecution();
 
 			do {
-				executeStage();
+				try {
+					executeStage();
+				} catch (StageException e) {
+					// TODO: handle exception
+				}
 			} while (!this.stage.shouldBeTerminated());
 
 			afterStageExecution();

src/main/java/teetime/framework/StageException.java → src/main/java/teetime/framework/exceptionHandling/StageException.java

-package teetime.framework;
+package teetime.framework.exceptionHandling;
+
+import teetime.framework.Stage;
 
 /**
  * Represents an Exception, which is thrown by stages, if uncatched exceptions are thrown.
  *
  */
-public class StageException extends Exception {
+public class StageException extends RuntimeException {
 
 	/**
 	 * Generated UID

src/main/java/teetime/framework/StageExceptionListener.java → src/main/java/teetime/framework/exceptionHandling/StageExceptionListener.java

-package teetime.framework;
+package teetime.framework.exceptionHandling;
+
+import teetime.framework.Stage;
 
 /**
  * Represent a minimalistic StageExceptionListener. Listener which extend from this one, must a least implement this functionality.