added a test for correct start and termination

src/test/java/teetime/framework/RunnableConsumerStageTest.java

@@ -54,6 +54,16 @@ public class RunnableConsumerStageTest {
 		thread.join();
 	}
 
+	@Test
+	public void testCorrectStartAndTerminatation() throws Exception {
+		RunnableConsumerStageTestConfiguration configuration = new RunnableConsumerStageTestConfiguration(0, 1, 2, 3, 5);
+
+		final Analysis analysis = new Analysis(configuration);
+		start(analysis);
+
+		assertEquals(5, configuration.getCollectedElements().size());
+	}
+
 	// @Test
 	// public void testWaitingInfinitely() throws Exception {
 	// WaitStrategyConfiguration waitStrategyConfiguration = new WaitStrategyConfiguration(300, 42);

src/test/java/teetime/framework/RunnableConsumerStageTestConfiguration.java

@@ -16,7 +16,9 @@ public class RunnableConsumerStageTestConfiguration extends AnalysisConfiguratio
 
 	public RunnableConsumerStageTestConfiguration(final Integer... inputElements) {
 		InitialElementProducer<Integer> producer = new InitialElementProducer<Integer>(inputElements);
-		// addThreadableStage(producer);
+		if (inputElements.length > 0) {
+			addThreadableStage(producer);
+		}
 
 		CollectorSink<Integer> collectorSink = new CollectorSink<Integer>(collectedElements);
 		addThreadableStage(collectorSink);