X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fwordcount%2Frecorder%2FRecorderApplicationIT.java;h=5f5893ecf0372f5dd75b222ff35887a10ba18e9a;hb=20648dca11997490c9e464afc07ccf15b9ef3e61;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..5f5893e 100644
--- a/src/test/java/de/juplo/kafka/wordcount/recorder/RecorderApplicationIT.java
+++ b/src/test/java/de/juplo/kafka/wordcount/recorder/RecorderApplicationIT.java
@@ -24,7 +24,7 @@ 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 +47,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";
 
@@ -64,15 +64,11 @@ 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 ->
+				.of(TestData.INPUT_MESSAGES)
+				.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));
 				});