From: Kai Moritz Date: Sun, 25 Feb 2024 19:43:43 +0000 (+0100) Subject: WIP:wait X-Git-Tag: rebase--2024-02-26--19-46~5 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=656f14addfa9276c98dea09ac62689ef1c480539;p=demos%2Fkafka%2Fchat WIP:wait --- 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 e6819979..7108ffb0 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java +++ b/src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java @@ -44,7 +44,6 @@ class KafkaHandoverIT extends AbstractHandoverIT .block()) .forEach(result -> log.info("{}", result)); - Thread.sleep(10000); receiveMessages(chatRoom).subscribe(message -> log.info("message: {}", message)); Thread.sleep(1000000); @@ -210,8 +209,8 @@ class KafkaHandoverIT extends AbstractHandoverIT result.getStdout()); BACKEND_1.start(); - BACKEND_2.start(); - BACKEND_3.start(); + // BACKEND_2.start(); + // BACKEND_3.start(); } static Network NETWORK = Network.newNetwork();