- .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);