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=aaed33ed0f0aeb8ee1ebfd7c179a7d830bcacd28;hpb=95229c5ee1ecc26082626dfa3206250f4280f888;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 aaed33e..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,7 +22,6 @@ 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.RecorderApplicationIT.TOPIC_OUT;
 import static org.assertj.core.api.Assertions.assertThat;
@@ -63,16 +62,12 @@ class RecorderApplicationIT
 	{
 		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));
 				});