diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagesCache.java b/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagesCache.java index 07f106dde..a60b4bd05 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagesCache.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/storage/MessagesCache.java @@ -127,6 +127,8 @@ public class MessagesCache extends RedisClusterPubSubAdapter imp } private void resubscribeAll() { + logger.info("Got topology change event, resubscribing all keyspace notifications"); + final Set queueNames; synchronized (messageListenersByQueueName) {