From 656f14addfa9276c98dea09ac62689ef1c480539 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Sun, 25 Feb 2024 20:43:43 +0100 Subject: [PATCH] WIP:wait --- .../java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java | 5 ++--- 1 file changed, 2 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 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(); -- 2.20.1