From: Kai Moritz Date: Wed, 28 Feb 2024 21:43:28 +0000 (+0100) Subject: test: HandoverIT-POC - Fixed illegal client-naming (one character only) X-Git-Tag: rebase--2024-03-03--11-38~19 X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=ded9ec7738de52fa16856c5baaeb1a34bef14cf4;p=demos%2Fkafka%2Fchat test: HandoverIT-POC - Fixed illegal client-naming (one character only) --- diff --git a/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java b/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java index 743b9bb4..b67a2db9 100644 --- a/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java +++ b/src/test/java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java @@ -43,12 +43,12 @@ public abstract class AbstractHandoverIT { ChatRoomInfoTo[] chatRooms = Flux .range(0, NUM_CHATROOMS) - .flatMap(i -> createChatRoom("#" + i)) + .flatMap(i -> createChatRoom("room-" + i)) .toStream() .toArray(size -> new ChatRoomInfoTo[size]); TestClient[] testClients = Flux - .fromStream(IntStream.range(0, NUM_CLIENTS).mapToObj(i -> Integer.toString(i))) + .fromStream(IntStream.range(0, NUM_CLIENTS).mapToObj(i -> "user-" + Integer.toString(i))) .map(i -> new TestClient( containers.haproxy.getMappedPort(8400), chatRooms,