first simple test

src/test/java/teetime/framework/ExceptionHandling.java

 package teetime.framework;
 
-import static org.junit.Assert.*;
+import static org.junit.Assert.assertEquals;
 
 import org.junit.Test;
 
+import teetime.framework.exceptionHandling.TestListener;
+
 public class ExceptionHandling {
 
 	@Test
-	public void test() {
-		fail("Not yet implemented");
+	public void exceptionPassingAndTermination() {
+		TestListener listener = new TestListener();
+		Analysis analysis = new Analysis(new ExceptionTestConfiguration(), listener);
+		analysis.init();
+		analysis.start();
+		assertEquals(TestListener.exceptionInvoked, 2);
 	}
-
 }

src/test/java/teetime/framework/ExceptionTestConfiguration.java

+package teetime.framework;
+
+public class ExceptionTestConfiguration extends AnalysisConfiguration {
+
+	public ExceptionTestConfiguration() {
+		this.addThreadableStage(new ExceptionTestStage());
+	}
+}

src/test/java/teetime/framework/ExceptionTestStage.java

+package teetime.framework;
+
+public class ExceptionTestStage extends AbstractProducerStage {
+
+	public int loops = 0;
+
+	@Override
+	protected void execute() {
+		if (loops % 1000 == 0) {
+			throw new IllegalStateException("1000 loops");
+		}
+		loops++;
+	}
+}

src/test/java/teetime/framework/exceptionHandling/TestListener.java

@@ -4,10 +4,16 @@ import teetime.framework.Stage;
 
 public class TestListener extends StageExceptionListener {
 
+	public static int exceptionInvoked = 0;
+
 	@Override
-	public FurtherExecution onStageException(Exception e, Stage throwingStage) {
-		// TODO Auto-generated method stub
-		return null;
+	public FurtherExecution onStageException(final Exception e, final Stage throwingStage) {
+		exceptionInvoked++;
+		if (exceptionInvoked == 2) {
+			return FurtherExecution.TERMINATE;
+		} else {
+			return FurtherExecution.CONTINUE;
+		}
 	}
 
 }