X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationTests.java;h=cd7d9283f0a879307930b159b6522e5f3ad69e29;hb=459f64072f3b657990a3bda0d39306208702d537;hp=cf70c81c8719ca46dab819d53b729a5c87642b7f;hpb=330b7238f03cdfafd72f9980ce0f019c46b02afe;p=demos%2Fkafka%2Ftraining

diff --git a/src/test/java/de/juplo/kafka/ApplicationTests.java b/src/test/java/de/juplo/kafka/ApplicationTests.java
index cf70c81..cd7d928 100644
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -51,7 +51,7 @@ public class ApplicationTests
 
 
 	@Test
-	void testSendMessage() throws Exception
+	void testSendClientMessage() throws Exception
 	{
 		mockMvc
 				.perform(post("/peter").content("Hallo Welt!"))
@@ -61,6 +61,28 @@ public class ApplicationTests
 				.until(() -> consumer.received.size() == 1);
 	}
 
+	@Test
+	void testSendFooMessage() throws Exception
+	{
+		mockMvc
+				.perform(put("/peter"))
+				.andExpect(status().isOk());
+		await("Message was send")
+				.atMost(Duration.ofSeconds(5))
+				.until(() -> consumer.received.size() == 1);
+	}
+
+	@Test
+	void testSendGreeting() throws Exception
+	{
+		mockMvc
+				.perform(post("/").content("peter"))
+				.andExpect(status().isOk());
+		await("Message was send")
+				.atMost(Duration.ofSeconds(5))
+				.until(() -> consumer.received.size() == 1);
+	}
+
 
 	static class Consumer
 	{