X-Git-Url: http://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2FApplicationTests.java;h=cd7d9283f0a879307930b159b6522e5f3ad69e29;hb=459f64072f3b657990a3bda0d39306208702d537;hp=d872c2f31c4c6a5ca9543f185900f89e964949bd;hpb=39d1bd1fc7b641255efd598ca4f037bd529d5fe8;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 d872c2f..cd7d928 100644
--- a/src/test/java/de/juplo/kafka/ApplicationTests.java
+++ b/src/test/java/de/juplo/kafka/ApplicationTests.java
@@ -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
 	{