From 6aa4acd3db8529330e619e47d8e6fb2923b6e5d6 Mon Sep 17 00:00:00 2001
From: Jon Chambers <jon@signal.org>
Date: Thu, 27 Aug 2020 13:38:15 -0400
Subject: [PATCH] Mirror "clear queue" operations to the clustered cache.

---
 .../whispersystems/textsecuregcm/storage/MessagesManager.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagesManager.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagesManager.java
index c9e526c0f..f582b43cf 100644
--- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagesManager.java
+++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagesManager.java
@@ -73,11 +73,13 @@ public class MessagesManager {
 
   public void clear(String destination, UUID destinationUuid) {
     this.messagesCache.clear(destination, destinationUuid);
+    this.clusterMessagesCache.clear(destination, destinationUuid);
     this.messages.clear(destination);
   }
 
   public void clear(String destination, UUID destinationUuid, long deviceId) {
     this.messagesCache.clear(destination, destinationUuid, deviceId);
+    this.clusterMessagesCache.clear(destination, destinationUuid, deviceId);
     this.messages.clear(destination, deviceId);
   }