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); }