X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Frecorder%2FRecorderApplicationIT.java;h=9d73e7ef0ef78d4c2e992965060713971b8d3f16;hb=2893aaa541057a9ab6a253b1995307c1f9fe0ed8;hp=3879d38efd1789c205559ffe5dcf71ef829dd474;hpb=928536af97a88dc121e1f5438b8fb671ee861960;p=demos%2Fkafka%2Fwordcount

diff --git a/src/test/java/de/juplo/kafka/wordcount/recorder/RecorderApplicationIT.java b/src/test/java/de/juplo/kafka/wordcount/recorder/RecorderApplicationIT.java
index 3879d38..9d73e7e 100644
--- a/src/test/java/de/juplo/kafka/wordcount/recorder/RecorderApplicationIT.java
+++ b/src/test/java/de/juplo/kafka/wordcount/recorder/RecorderApplicationIT.java
@@ -22,9 +22,8 @@ import org.springframework.util.MultiValueMap;
 
 import java.time.Duration;
 import java.util.List;
-import java.util.stream.Stream;
 
-import static de.juplo.kafka.wordcount.recorder.ApplicationTests.TOPIC_OUT;
+import static de.juplo.kafka.wordcount.recorder.RecorderApplicationIT.TOPIC_OUT;
 import static org.assertj.core.api.Assertions.assertThat;
 import static org.awaitility.Awaitility.await;
 import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.asyncDispatch;
@@ -47,7 +46,7 @@ import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.
 @AutoConfigureMockMvc
 @EmbeddedKafka(topics = { TOPIC_OUT })
 @Slf4j
-class ApplicationTests
+class RecorderApplicationIT
 {
 	static final String TOPIC_OUT = "out";
 
@@ -63,16 +62,12 @@ class ApplicationTests
 	{
 		MultiValueMap<String, TestRecording> recordings = new LinkedMultiValueMap<>();
 
-		Stream
-				.of(
-						new TestRecording("päter", "Hall° Wält?¢*&%€!"),
-						new TestRecording("päter", "Hallo Welt!"),
-						new TestRecording("klühs", "Müsch gäb's auch!"),
-						new TestRecording("päter", "Boäh, echt! ß mal nä Nümmäh!"))
-				.forEach(recording ->
+		TestData
+				.getInputMessages()
+				.forEach(kv ->
 				{
-					sendRedording(recording.getUser(), recording.getSentence());
-					recordings.add(recording.getUser(), recording);
+					sendRedording(kv.key, kv.value);
+					recordings.add(kv.key, TestRecording.of(kv.key, kv.value));
 				});