projects
/
demos
/
kafka
/
chat
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
test: HandoverIT-POC - Each `TestWriter` writes only to one chat-room
[demos/kafka/chat]
/
src
/
test
/
java
/
de
/
juplo
/
kafka
/
chat
/
backend
/
TestWriter.java
diff --git
a/src/test/java/de/juplo/kafka/chat/backend/TestWriter.java
b/src/test/java/de/juplo/kafka/chat/backend/TestWriter.java
index
076376e
..
929d84f
100644
(file)
--- a/
src/test/java/de/juplo/kafka/chat/backend/TestWriter.java
+++ b/
src/test/java/de/juplo/kafka/chat/backend/TestWriter.java
@@
-24,7
+24,7
@@
public class TestWriter implements Runnable
for (int i = 0; running; i++)
{
String message = "Message #" + i;
for (int i = 0; running; i++)
{
String message = "Message #" + i;
- for (ChatRoomInfoTo chatRoom : chatRooms)
+ try
{
sendMessage(chatRoom, message)
.retryWhen(Retry.fixedDelay(10, Duration.ofSeconds(1)))
{
sendMessage(chatRoom, message)
.retryWhen(Retry.fixedDelay(10, Duration.ofSeconds(1)))
@@
-39,9
+39,7
@@
public class TestWriter implements Runnable
user,
chatRoom,
result));
user,
chatRoom,
result));
- }
- try
- {
+
Thread.sleep(ThreadLocalRandom.current().nextLong(700, 1000));
}
catch (Exception e)
Thread.sleep(ThreadLocalRandom.current().nextLong(700, 1000));
}
catch (Exception e)
@@
-80,16
+78,16
@@
public class TestWriter implements Runnable
private final WebClient webClient;
private final WebClient webClient;
- private final ChatRoomInfoTo
[] chatRooms
;
+ private final ChatRoomInfoTo
chatRoom
;
private final User user;
volatile boolean running = true;
private final User user;
volatile boolean running = true;
- TestWriter(Integer port, ChatRoomInfoTo
[] chatRooms
, String username)
+ TestWriter(Integer port, ChatRoomInfoTo
chatRoom
, String username)
{
webClient = WebClient.create("http://localhost:" + port);
{
webClient = WebClient.create("http://localhost:" + port);
- this.chatRoom
s = chatRooms
;
+ this.chatRoom
= chatRoom
;
user = new User(username);
}
}
user = new User(username);
}
}