diff --git a/src/test/java/kieker/analysis/plugin/reader/jms/JMSReaderTest.java b/src/test/java/kieker/analysis/plugin/reader/jms/JMSReaderTest.java
index 643b39bf7d12b5c18152d172631558b8c6e08b9d..6156d91938d31e210c6a326d62e518b2c3971b6f 100644
--- a/src/test/java/kieker/analysis/plugin/reader/jms/JMSReaderTest.java
+++ b/src/test/java/kieker/analysis/plugin/reader/jms/JMSReaderTest.java
@@ -3,6 +3,7 @@ package kieker.analysis.plugin.reader.jms;
 import static teetime.framework.test.StageTester.test;
 
 import java.util.Hashtable;
+import java.util.LinkedList;
 import java.util.List;
 
 import javax.jms.Connection;
@@ -57,15 +58,20 @@ public class JMSReaderTest {
 	@Test
 	public void jmsReaderShouldReadCorrectRecords() {
 		produceJMSMessage();
-		List<Object> outputList = null;
-		test(jmsReader).and().receive(outputList).from(jmsReader.getOutputPort()).start();
+		new ReaderTest().start();
+
+	}
+
+	private class ReaderTest extends Thread {
+		@Override
+		public void run() {
+			List<Object> outputList = new LinkedList<>();
+			test(jmsReader).and().receive(outputList).from(jmsReader.getOutputPort()).start();
 
-		if (outputList != null) {
 			for (Object elem : outputList) {
 				System.out.println("Received" + elem);
 			}
 		}
-
 	}
 
 	public void produceJMSMessage() {