From 3e02c574e7f9b1a7bb6cbc1631d0e510860019d7 Mon Sep 17 00:00:00 2001
From: Jon Chambers <jon@signal.org>
Date: Tue, 29 Sep 2020 13:42:55 -0400
Subject: [PATCH] Log exceptions when persisting messages.

---
 .../textsecuregcm/storage/MessagePersister.java           | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagePersister.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagePersister.java
index f969f40b4..455049cec 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagePersister.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagePersister.java
@@ -65,7 +65,13 @@ public class MessagePersister implements Managed {
             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