Mirror "clear queue" operations to the clustered cache.

This commit is contained in:
Jon Chambers
2020-08-27 13:38:15 -04:00
committed by Jon Chambers
parent 15936c29c1
commit 6aa4acd3db

View File

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