- .delayElement(Duration.ofMillis(ThreadLocalRandom.current().nextLong(500, 1500)))
- .retryWhen(Retry.fixedDelay(10, Duration.ofSeconds(1))))
- .doOnNext(message -> log.info(
- "{} sent a message to {}: {}",
- user,
- chatRoom,
- message))
+ .retryWhen(Retry.fixedDelay(30, Duration.ofSeconds(1))))
+ .doOnNext(message ->
+ {
+ numSentMessages++;
+ sentMessages.add(message);
+ log.info(
+ "{} sent a message to {}: {}",
+ user,
+ chatRoom,
+ message);
+ })