WIP

diff --git a/src/test/java/de/juplo/kafka/wordcount/recorder/ApplicationTests.java b/src/test/java/de/juplo/kafka/wordcount/recorder/ApplicationTests.java
index 0a70993..19bb8f5 100644 (file)
--- a/src/test/java/de/juplo/kafka/wordcount/recorder/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/wordcount/recorder/ApplicationTests.java
@@ -13,11 +13,13 @@ import org.springframework.http.MediaType;
 import org.springframework.kafka.annotation.KafkaListener;
 import org.springframework.kafka.test.context.EmbeddedKafka;
 import org.springframework.test.web.servlet.MockMvc;
+import org.springframework.test.web.servlet.MvcResult;
 import org.springframework.util.LinkedMultiValueMap;
 import org.springframework.util.MultiValueMap;
 
 import static de.juplo.kafka.wordcount.recorder.ApplicationTests.PARTITIONS;
 import static de.juplo.kafka.wordcount.recorder.ApplicationTests.TOPIC_OUT;
+import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.asyncDispatch;
 import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.post;
 import static org.springframework.test.web.servlet.result.MockMvcResultHandlers.print;
 import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.jsonPath;
@@ -52,10 +54,13 @@ class ApplicationTests
        @Test
        void userMessagesAreExceptedAndSentToKafka() throws Exception
        {
-               mockMvc
+               MvcResult result = mockMvc
                                .perform(post("/{user}", USER)
                                                .contentType(MediaType.TEXT_PLAIN)
                                                .content(SENTENCE))
+                               .andReturn();
+
+               mockMvc.perform(asyncDispatch(result))
                                .andDo(print())
                                .andExpect(status().isOk())
                                .andExpect(jsonPath("$.username").value(USER))