WIP

[demos/kafka/chat] / src / test / java / de / juplo / kafka / chat / backend / AbstractConfigurationIT.java

diff --git a/src/test/java/de/juplo/kafka/chat/backend/AbstractConfigurationIT.java b/src/test/java/de/juplo/kafka/chat/backend/AbstractConfigurationIT.java
index e1e87c5..c357f78 100644 (file)
--- a/src/test/java/de/juplo/kafka/chat/backend/AbstractConfigurationIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/AbstractConfigurationIT.java
@@ -55,65 +55,81 @@ public abstract class AbstractConfigurationIT
   @DisplayName("Restored chat-rooms can be listed")
   void testRestoredChatRoomsCanBeListed()
   {
-    webTestClient
-        .get()
-        .uri(
-            "http://localhost:{port}/list",
-            port)
-        .accept(MediaType.APPLICATION_JSON)
-        .exchange()
-        .expectStatus().isOk()
-        .expectBody()
-        .jsonPath("$.length()").isEqualTo(1)
-        .jsonPath("$[0].name").isEqualTo("FOO");
+    Awaitility
+        .await()
+        .atMost(Duration.ofSeconds(15))
+        .untilAsserted(() ->
+            webTestClient
+                .get()
+                .uri(
+                    "http://localhost:{port}/list",
+                    port)
+                .accept(MediaType.APPLICATION_JSON)
+                .exchange()
+                .expectStatus().isOk()
+                .expectBody()
+                .jsonPath("$.length()").isEqualTo(1)
+                .jsonPath("$[0].name").isEqualTo("FOO"));
   }
 
   @Test
   @DisplayName("Details as expected for restored chat-room")
   void testRestoredChatRoomHasExpectedDetails()
   {
-    webTestClient
-        .get()
-        .uri(
-            "http://localhost:{port}/{chatRoomId}",
-            port,
-            EXISTING_CHATROOM)
-        .accept(MediaType.APPLICATION_JSON)
-        .exchange()
-        .expectStatus().isOk()
-        .expectBody().jsonPath("$.name").isEqualTo("FOO");
+    Awaitility
+        .await()
+        .atMost(Duration.ofSeconds(15))
+        .untilAsserted(() ->
+            webTestClient
+                .get()
+                .uri(
+                    "http://localhost:{port}/{chatRoomId}",
+                    port,
+                    EXISTING_CHATROOM)
+                .accept(MediaType.APPLICATION_JSON)
+                .exchange()
+                .expectStatus().isOk()
+                .expectBody().jsonPath("$.name").isEqualTo("FOO"));
   }
 
   @Test
   @DisplayName("Restored message from Ute has expected Text")
   void testRestoredMessageForUteHasExpectedText()
   {
-    webTestClient
-        .get()
-        .uri(
-            "http://localhost:{port}/{chatRoomId}/ute/1",
-            port,
-            EXISTING_CHATROOM)
-        .accept(MediaType.APPLICATION_JSON)
-        .exchange()
-        .expectStatus().isOk()
-        .expectBody().jsonPath("$.text").isEqualTo("Ich bin Ute...");
+    Awaitility
+        .await()
+        .atMost(Duration.ofSeconds(15))
+        .untilAsserted(() ->
+            webTestClient
+                .get()
+                .uri(
+                    "http://localhost:{port}/{chatRoomId}/ute/1",
+                    port,
+                    EXISTING_CHATROOM)
+                .accept(MediaType.APPLICATION_JSON)
+                .exchange()
+                .expectStatus().isOk()
+                .expectBody().jsonPath("$.text").isEqualTo("Ich bin Ute..."));
   }
 
   @Test
   @DisplayName("Restored message from Peter has expected Text")
   void testRestoredMessageForPeterHasExpectedText()
   {
-    webTestClient
-        .get()
-        .uri(
-            "http://localhost:{port}/{chatRoomId}/peter/1",
-            port,
-            EXISTING_CHATROOM)
-        .accept(MediaType.APPLICATION_JSON)
-        .exchange()
-        .expectStatus().isOk()
-        .expectBody().jsonPath("$.text").isEqualTo("Hallo, ich heiße Peter!");
+    Awaitility
+        .await()
+        .atMost(Duration.ofSeconds(15))
+        .untilAsserted(() ->
+            webTestClient
+                .get()
+                .uri(
+                    "http://localhost:{port}/{chatRoomId}/peter/1",
+                    port,
+                    EXISTING_CHATROOM)
+                .accept(MediaType.APPLICATION_JSON)
+                .exchange()
+                .expectStatus().isOk()
+                .expectBody().jsonPath("$.text").isEqualTo("Hallo, ich heiße Peter!"));
   }
 
   @Test