From: Kai Moritz Date: Mon, 26 Feb 2024 14:13:51 +0000 (+0100) Subject: WIP:poc-setup X-Git-Tag: rebase--2024-02-26--19-46~1 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=03a4825d54a803e6a6ed1e3559ccd2c366b374a3;p=demos%2Fkafka%2Fchat WIP:poc-setup --- 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 35e261c7..92306c70 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java +++ b/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java @@ -46,7 +46,13 @@ class KafkaHandoverIT extends AbstractHandoverIT .block()) .forEach(result -> log.info("{}", result)); - receiveMessages(chatRoom).subscribe(message -> log.info("message: {}", message)); + Long count = receiveMessages(chatRoom) + .doOnNext(message -> log.info("message: {}", message)) + .count() + .block(); + log.info("Received {} messages", count); + + Thread.sleep(1000); } Mono createChatRoom(String name)