X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2FTestWriter.java;h=076376e817e7d9f94f466b24a7631ba586936044;hb=252c385469bf59e75757d5cd1946e4cc4e57f7f5;hp=0d54600d17094e49bc966e143992bdd7017c5683;hpb=d01255379f60b7be221690a1ad89349bf477d50a;p=demos%2Fkafka%2Fchat 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 0d54600d..076376e8 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/TestWriter.java +++ b/src/test/java/de/juplo/kafka/chat/backend/TestWriter.java @@ -16,7 +16,7 @@ import java.util.concurrent.ThreadLocalRandom; @Slf4j -public class TestClient implements Runnable +public class TestWriter implements Runnable { @Override public void run() @@ -86,7 +86,7 @@ public class TestClient implements Runnable volatile boolean running = true; - TestClient(Integer port, ChatRoomInfoTo[] chatRooms, String username) + TestWriter(Integer port, ChatRoomInfoTo[] chatRooms, String username) { webClient = WebClient.create("http://localhost:" + port); this.chatRooms = chatRooms;