import reactor.util.retry.Retry;
import java.time.Duration;
+import java.util.concurrent.ThreadLocalRandom;
@Slf4j
-public class TestClient
+public class TestClient implements Runnable
{
+ @Override
public void run()
{
- for (int i = 0; i < 100; i++)
+ for (int i = 0; running; i++)
{
String message = "Message #" + i;
for (ChatRoomInfoTo chatRoom : chatRooms)
message,
chatRoom));
}
+ try
+ {
+ Thread.sleep(ThreadLocalRandom.current().nextLong(700, 1000));
+ }
+ catch (Exception e)
+ {
+ throw new RuntimeException(e);
+ }
}
}
private final ChatRoomInfoTo[] chatRooms;
private final User user;
+ volatile boolean running = true;
+
TestClient(Integer port, ChatRoomInfoTo[] chatRooms, String username)
{