From e09dd4e4fb991a1b773f80845c38de169effe730 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sun, 25 Feb 2024 20:42:59 +0100
Subject: [PATCH] WIP:FIX

---
 .../java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java   | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java b/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
index cc5039ed..e6819979 100644
--- a/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
+++ b/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
@@ -45,7 +45,7 @@ class KafkaHandoverIT extends AbstractHandoverIT
         .forEach(result -> log.info("{}", result));
 
     Thread.sleep(10000);
-    receiveMessage(chatRoom).subscribe(message -> log.info("message: {}", message));
+    receiveMessages(chatRoom).subscribe(message -> log.info("message: {}", message));
 
     Thread.sleep(1000000);
   }
@@ -99,12 +99,12 @@ class KafkaHandoverIT extends AbstractHandoverIT
         });
   }
 
-  Flux<byte[]> receiveMessage(ChatRoomInfoTo chatRoom)
+  Flux<byte[]> receiveMessages(ChatRoomInfoTo chatRoom)
   {
     return webClient
         .get()
         .uri(
-            "/{chatRoomId}",
+            "/{chatRoomId}/listen",
             chatRoom.getId())
         .accept(MediaType.APPLICATION_OCTET_STREAM)
         .retrieve()
-- 
2.20.1