From 38121bcbfa31ca119f21a30b206a0185f834e737 Mon Sep 17 00:00:00 2001 From: Jon Chambers Date: Mon, 16 Mar 2026 09:54:45 -0400 Subject: [PATCH] Use a shorter default node claim TTL --- .../dynamic/DynamicMessagePersisterConfiguration.java | 2 +- .../textsecuregcm/storage/MessagePersisterIntegrationTest.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) 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);