andreacavalli/tdlib-session-container
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Don't print stacktrace if the bot is not found

Browse Source
This commit is contained in:
Andrea Cavalli 2022-01-19 23:53:02 +01:00
parent 101e9a814e
commit 79bfd5d95c
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/main/java/it/tdlight/reactiveapi/PeriodicRestarter.java
View File

@ -24,6 +24,7 @@ import org.slf4j.LoggerFactory;
import reactor.core.Disposable; import reactor.core.Disposable;
import reactor.core.publisher.Mono; import reactor.core.publisher.Mono;
import reactor.core.scheduler.Schedulers; import reactor.core.scheduler.Schedulers;
import reactor.util.retry.Retry;
public class PeriodicRestarter { public class PeriodicRestarter {
@ -140,8 +141,14 @@ public class PeriodicRestarter {
multiClient multiClient
.request(userId, liveId, new Close(), Instant.now().plus(Duration.ofSeconds(15))) .request(userId, liveId, new Close(), Instant.now().plus(Duration.ofSeconds(15)))
.subscribeOn(Schedulers.parallel()) .subscribeOn(Schedulers.parallel())
.retry(5) .retryWhen(Retry.backoff(5, Duration.ofSeconds(1)).maxBackoff(Duration.ofSeconds(5)))
.doOnError(ex -> LOG.error("Failed to restart bot {} (liveId={})", userId, liveId, ex)) .doOnError(ex -> {
if (ex instanceof TdError tdError && tdError.getTdCode() == 404) {
LOG.warn("Failed to restart bot {} (liveId={}): not found", userId, liveId);
} else {
LOG.error("Failed to restart bot {} (liveId={})", userId, liveId, ex);
}
})
.onErrorResume(ex -> Mono.empty()) .onErrorResume(ex -> Mono.empty())
.subscribe(); .subscribe();
} }