diff --git a/src/test/java/teetime/framework/RunnableConsumerStageTest.java b/src/test/java/teetime/framework/RunnableConsumerStageTest.java
index e2d1771d20387d25ff8dbcf87ef3d95ba2d5c3c6..4399cd68026aec3cbc667937e5e208b255594805 100644
--- a/src/test/java/teetime/framework/RunnableConsumerStageTest.java
+++ b/src/test/java/teetime/framework/RunnableConsumerStageTest.java
@@ -15,7 +15,7 @@ public class RunnableConsumerStageTest {
 
 	@Test
 	public void testWaitingInfinitely() throws Exception {
-		WaitStrategyConfiguration waitStrategyConfiguration = new WaitStrategyConfiguration(300, 1);
+		WaitStrategyConfiguration waitStrategyConfiguration = new WaitStrategyConfiguration(300, 42);
 
 		final Analysis analysis = new Analysis(waitStrategyConfiguration);
 		analysis.init();
@@ -35,7 +35,7 @@ public class RunnableConsumerStageTest {
 
 	@Test
 	public void testWaitingFinitely() throws Exception {
-		WaitStrategyConfiguration waitStrategyConfiguration = new WaitStrategyConfiguration(300, 1);
+		WaitStrategyConfiguration waitStrategyConfiguration = new WaitStrategyConfiguration(300, 42);
 
 		final Analysis analysis = new Analysis(waitStrategyConfiguration);
 		analysis.init();
@@ -47,13 +47,10 @@ public class RunnableConsumerStageTest {
 		});
 		thread.start();
 
-		Thread.sleep(200);
-		assertEquals(State.WAITING, thread.getState());
-		assertEquals(0, waitStrategyConfiguration.getCollectorSink().getElements().size());
+		Thread.sleep(400);
 
-		Thread.sleep(200);
 		assertEquals(State.TERMINATED, thread.getState());
-		assertEquals(1, waitStrategyConfiguration.getCollectorSink().getElements().get(0));
+		assertEquals(42, waitStrategyConfiguration.getCollectorSink().getElements().get(0));
 		assertEquals(1, waitStrategyConfiguration.getCollectorSink().getElements().size());
 	}