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++)
message,
chatRoom));
}
+ try
+ {
+ Thread.sleep(ThreadLocalRandom.current().nextLong(700, 1000));
+ }
+ catch (Exception e)
+ {
+ throw new RuntimeException(e);
+ }
}
}