diff --git a/service/src/main/java/org/whispersystems/textsecuregcm/configuration/dynamic/DynamicMessagePersisterConfiguration.java b/service/src/main/java/org/whispersystems/textsecuregcm/configuration/dynamic/DynamicMessagePersisterConfiguration.java index 50bd146b7..3ca0f5d2a 100644 --- a/service/src/main/java/org/whispersystems/textsecuregcm/configuration/dynamic/DynamicMessagePersisterConfiguration.java +++ b/service/src/main/java/org/whispersystems/textsecuregcm/configuration/dynamic/DynamicMessagePersisterConfiguration.java @@ -21,7 +21,7 @@ public class DynamicMessagePersisterConfiguration { private double trimOversizedQueueExtraRoomRatio = 1.5; @JsonProperty - private Duration nodeClaimTtl = Duration.ofHours(1); + private Duration nodeClaimTtl = Duration.ofMinutes(5); @JsonProperty private Duration sleepBetweenNodes = Duration.ofSeconds(5); diff --git a/service/src/test/java/org/whispersystems/textsecuregcm/storage/MessagePersisterIntegrationTest.java b/service/src/test/java/org/whispersystems/textsecuregcm/storage/MessagePersisterIntegrationTest.java index c4da1e676..098d39f80 100644 --- a/service/src/test/java/org/whispersystems/textsecuregcm/storage/MessagePersisterIntegrationTest.java +++ b/service/src/test/java/org/whispersystems/textsecuregcm/storage/MessagePersisterIntegrationTest.java @@ -78,7 +78,7 @@ class MessagePersisterIntegrationTest { final DynamicConfiguration dynamicConfiguration = mock(DynamicConfiguration.class); when(dynamicConfiguration.getMessagePersisterConfiguration()) - .thenReturn(new DynamicMessagePersisterConfiguration(true, 1.5, Duration.ofHours(1), Duration.ZERO)); + .thenReturn(new DynamicMessagePersisterConfiguration(true, 1.5, Duration.ofMinutes(5), Duration.ZERO)); when(dynamicConfigurationManager.getConfiguration()).thenReturn(dynamicConfiguration);