Skip to content

Commit 369b549

Browse files
committed
Default Lettuce shutdownQuietPeriod to zero.
Use a lower timeout for faster shutdown. Also, the quiet period is no longer configured through the shutdown timeout. Closes #2945
1 parent ba2c9ba commit 369b549

File tree

4 files changed

+9
-10
lines changed

4 files changed

+9
-10
lines changed

src/main/java/org/springframework/data/redis/connection/lettuce/DefaultLettuceClientConfiguration.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ class DefaultLettuceClientConfiguration implements LettuceClientConfiguration {
5151
DefaultLettuceClientConfiguration(boolean useSsl, SslVerifyMode verifyMode, boolean startTls,
5252
@Nullable ClientResources clientResources, @Nullable ClientOptions clientOptions, @Nullable String clientName,
5353
@Nullable ReadFrom readFrom, @Nullable RedisCredentialsProviderFactory redisCredentialsProviderFactory,
54-
Duration timeout, Duration shutdownTimeout, @Nullable Duration shutdownQuietPeriod) {
54+
Duration timeout, Duration shutdownTimeout, Duration shutdownQuietPeriod) {
5555

5656
this.useSsl = useSsl;
5757
this.verifyMode = verifyMode;
@@ -63,7 +63,7 @@ class DefaultLettuceClientConfiguration implements LettuceClientConfiguration {
6363
this.redisCredentialsProviderFactory = Optional.ofNullable(redisCredentialsProviderFactory);
6464
this.timeout = timeout;
6565
this.shutdownTimeout = shutdownTimeout;
66-
this.shutdownQuietPeriod = shutdownQuietPeriod != null ? shutdownQuietPeriod : shutdownTimeout;
66+
this.shutdownQuietPeriod = shutdownQuietPeriod;
6767
}
6868

6969
@Override

src/main/java/org/springframework/data/redis/connection/lettuce/LettuceClientConfiguration.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -185,7 +185,7 @@ class LettuceClientConfigurationBuilder {
185185
@Nullable RedisCredentialsProviderFactory redisCredentialsProviderFactory;
186186
Duration timeout = Duration.ofSeconds(RedisURI.DEFAULT_TIMEOUT);
187187
Duration shutdownTimeout = Duration.ofMillis(100);
188-
@Nullable Duration shutdownQuietPeriod;
188+
Duration shutdownQuietPeriod = Duration.ZERO;
189189

190190
LettuceClientConfigurationBuilder() {}
191191

src/test/java/org/springframework/data/redis/connection/lettuce/LettuceClientConfigurationUnitTests.java

+4-5
Original file line numberDiff line numberDiff line change
@@ -39,12 +39,11 @@
3939
*/
4040
class LettuceClientConfigurationUnitTests {
4141

42-
@Test // DATAREDIS-574, DATAREDIS-576, DATAREDIS-667, DATAREDIS-918
42+
@Test // DATAREDIS-574, DATAREDIS-576, DATAREDIS-667, DATAREDIS-918, GH-2945
4343
void shouldCreateEmptyConfiguration() {
4444

4545
LettuceClientConfiguration configuration = LettuceClientConfiguration.defaultConfiguration();
4646

47-
4847
assertThat(configuration.isUseSsl()).isFalse();
4948
assertThat(configuration.isVerifyPeer()).isTrue();
5049
assertThat(configuration.getVerifyMode().equals(SslVerifyMode.FULL));
@@ -58,7 +57,7 @@ void shouldCreateEmptyConfiguration() {
5857
assertThat(configuration.getClientName()).isEmpty();
5958
assertThat(configuration.getCommandTimeout()).isEqualTo(Duration.ofSeconds(60));
6059
assertThat(configuration.getShutdownTimeout()).isEqualTo(Duration.ofMillis(100));
61-
assertThat(configuration.getShutdownQuietPeriod()).isEqualTo(Duration.ofMillis(100));
60+
assertThat(configuration.getShutdownQuietPeriod()).isEqualTo(Duration.ZERO);
6261
}
6362

6463
@Test // DATAREDIS-574, DATAREDIS-576, DATAREDIS-667
@@ -92,13 +91,13 @@ void shouldConfigureAllProperties() {
9291
}
9392

9493
@Test // DATAREDIS-881
95-
void shutdownQuietPeriodShouldDefaultToTimeout() {
94+
void shutdownQuietPeriodShouldDefaultInitialValue() {
9695

9796
LettuceClientConfiguration configuration = LettuceClientConfiguration.builder()
9897
.shutdownTimeout(Duration.ofSeconds(42)).build();
9998

10099
assertThat(configuration.getShutdownTimeout()).isEqualTo(Duration.ofSeconds(42));
101-
assertThat(configuration.getShutdownQuietPeriod()).isEqualTo(Duration.ofSeconds(42));
100+
assertThat(configuration.getShutdownQuietPeriod()).isEqualTo(Duration.ZERO);
102101
}
103102

104103
@Test // DATAREDIS-576

src/test/java/org/springframework/data/redis/connection/lettuce/LettucePoolingClientConfigurationUnitTests.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@
4040
*/
4141
class LettucePoolingClientConfigurationUnitTests {
4242

43-
@Test // DATAREDIS-667, DATAREDIS-918
43+
@Test // DATAREDIS-667, DATAREDIS-918, GH-2945
4444
void shouldCreateEmptyConfiguration() {
4545

4646
LettucePoolingClientConfiguration configuration = LettucePoolingClientConfiguration.defaultConfiguration();
@@ -58,7 +58,7 @@ void shouldCreateEmptyConfiguration() {
5858
assertThat(configuration.getClientResources()).isEmpty();
5959
assertThat(configuration.getCommandTimeout()).isEqualTo(Duration.ofSeconds(60));
6060
assertThat(configuration.getShutdownTimeout()).isEqualTo(Duration.ofMillis(100));
61-
assertThat(configuration.getShutdownQuietPeriod()).isEqualTo(Duration.ofMillis(100));
61+
assertThat(configuration.getShutdownQuietPeriod()).isEqualTo(Duration.ZERO);
6262
}
6363

6464
@Test // DATAREDIS-667

0 commit comments

Comments
 (0)