diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerConfiguration.java b/service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerConfiguration.java index a2ba77abb..ef64e6908 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerConfiguration.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerConfiguration.java @@ -112,6 +112,11 @@ public class WhisperServerConfiguration extends Configuration { @JsonProperty private MessageCacheConfiguration messageCache; + @NotNull + @Valid + @JsonProperty + private RedisClusterConfiguration clientPresenceCluster; + @Valid @NotNull @JsonProperty @@ -274,6 +279,10 @@ public class WhisperServerConfiguration extends Configuration { return messageCache; } + public RedisClusterConfiguration getClientPresenceClusterConfiguration() { + return clientPresenceCluster; + } + public RedisConfiguration getPushScheduler() { return pushScheduler; } diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerService.java b/service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerService.java index 2a6c11914..98b264c96 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerService.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerService.java @@ -283,7 +283,7 @@ public class WhisperServerService extends Application keyspaceNotificationDispatchQueue = new ArrayBlockingQueue<>(10_000);