Signal/Signal-Server
1
0
Fork 0
mirror of https://github.com/signalapp/Signal-Server synced 2026-04-17 13:33:25 +01:00
Code Issues Packages Projects Releases Wiki Activity

Add better logging for unhandled persister errors

Browse Source
This commit is contained in:
Jon Chambers
2026-03-12 11:48:49 -04:00
committed by Jon Chambers
parent 3350922456
commit b647853983
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagePersister.java
View File

@@ -24,7 +24,6 @@ import java.util.List;
import java.util.Locale;
import java.util.Optional;
import java.util.UUID;
import java.util.concurrent.Executor;
import java.util.concurrent.atomic.AtomicLong;
import javax.annotation.Nullable;
import org.apache.commons.lang3.tuple.Pair;
@@ -38,7 +37,6 @@ import org.whispersystems.textsecuregcm.util.Util;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import reactor.core.scheduler.Scheduler;
import reactor.core.scheduler.Schedulers;
import reactor.util.function.Tuples;
import reactor.util.retry.Retry;
import reactor.util.retry.RetryBackoffSpec;
@@ -251,6 +249,10 @@ public class MessagePersister implements Managed {
return Mono.empty();
});
}, maxConcurrency)
.onErrorResume(e -> {
logger.warn("Unhandled error while persisting messages", e);
return Mono.empty();
})
.count()
.blockOptional()
.map(Math::toIntExact)