From ccfc613706cbb127fe5dea3dad15c4debeb0991e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Lars=20Blu=CC=88mke?= <lbl@informatik.uni-kiel.de>
Date: Wed, 18 May 2016 08:31:41 +0200
Subject: [PATCH] small changes
---
.../analysis/plugin/reader/jms/JMSReaderTest.java | 14 ++++++++++----
1 file changed, 10 insertions(+), 4 deletions(-)
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 643b39bf..6156d919 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() {
--
GitLab