projects
/
demos
/
kafka
/
chat
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
| inline |
side by side
(parent:
e09dd4e
)
WIP:wait
author
Kai Moritz
<kai@juplo.de>
Sun, 25 Feb 2024 19:43:43 +0000
(20:43 +0100)
committer
Kai Moritz
<kai@juplo.de>
Sun, 25 Feb 2024 19:43:43 +0000
(20:43 +0100)
src/test/java/de/juplo/kafka/chat/backend/KafkaHandoverIT.java
patch
|
blob
|
history
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
e681997
..
7108ffb
100644
(file)
--- 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();