MirrorMirror
/
Signal-Server
mirror of https://github.com/signalapp/Signal-Server.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Log exceptions when persisting messages.

This commit is contained in:
Jon Chambers 2020-09-29 13:42:55 -04:00 committed by Jon Chambers
parent e873d55cd3
commit 3e02c574e7
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -65,7 +65,13 @@ public class MessagePersister implements Managed {
persistQueuesFuture.cancel(false); persistQueuesFuture.cancel(false);
} }
persistQueuesFuture = scheduledExecutorService.scheduleWithFixedDelay(() -> this.persistNextQueues(Instant.now()), 0, 100, TimeUnit.MILLISECONDS); persistQueuesFuture = scheduledExecutorService.scheduleWithFixedDelay(() -> {
try {
persistNextQueues(Instant.now());
} catch (final Exception e) {
logger.warn("Failed to persist queues", e);
}
}, 0, 100, TimeUnit.MILLISECONDS);
} }
@Override @Override