retry msg send once on timeout error

rfresh2 · Nov 5, 2023 · f356857 · f356857
1 parent 18ce6fd
commit f356857
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/main/java/vc/live/LiveFeed.java b/src/main/java/vc/live/LiveFeed.java
@@ -15,6 +15,7 @@
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 import reactor.core.scheduler.Schedulers;
+import reactor.util.retry.Retry;
 import vc.config.GuildConfigManager;
 import vc.config.GuildConfigRecord;
 
@@ -190,6 +191,9 @@ private Mono<?> processSend(final Map.Entry<String, RestChannel> entry, final Li
                     .embeds(embeds)
                     .build())
             .timeout(Duration.ofSeconds(3))
+            // retry only on TimeoutException
+            .retryWhen(Retry.fixedDelay(1, Duration.ofSeconds(1))
+                           .filter(error -> error instanceof TimeoutException))
             .onErrorResume(error -> {
                 if (error instanceof ClientException e) {
                     int code = e.getStatus().code();