From ded9ec7738de52fa16856c5baaeb1a34bef14cf4 Mon Sep 17 00:00:00 2001 From: Kai Moritz Date: Wed, 28 Feb 2024 22:43:28 +0100 Subject: [PATCH] test: HandoverIT-POC - Fixed illegal client-naming (one character only) --- .../java/de/juplo/kafka/chat/backend/AbstractHandoverIT.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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, -- 2.20.1