Skip to content

Commit cc04e3f

Browse files
committed
Correctly return connection future from StaticMasterReplicaConnectionProvider.
We now pass on the connection future when connecting through StaticMasterReplicaConnectionProvider.getConnectionAsync(…). Closes #2296
1 parent c0b48f7 commit cc04e3f

File tree

2 files changed

+80
-2
lines changed

2 files changed

+80
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -98,10 +98,10 @@ class StaticMasterReplicaConnectionProvider implements LettuceConnectionProvider
9898
CompletableFuture<? extends StatefulRedisMasterReplicaConnection<?, ?>> connection = MasterReplica
9999
.connectAsync(client, codec, nodes);
100100

101-
connection.thenApply(it -> {
101+
return connection.thenApply(it -> {
102102

103103
readFrom.ifPresent(readFrom -> it.setReadFrom(readFrom));
104-
return connectionType.cast(connection);
104+
return connectionType.cast(it);
105105
});
106106
}
107107

Original file line numberDiff line numberDiff line change
@@ -0,0 +1,78 @@
1+
/*
2+
* Copyright 2022 the original author or authors.
3+
*
4+
* Licensed under the Apache License, Version 2.0 (the "License");
5+
* you may not use this file except in compliance with the License.
6+
* You may obtain a copy of the License at
7+
*
8+
* https://www.apache.org/licenses/LICENSE-2.0
9+
*
10+
* Unless required by applicable law or agreed to in writing, software
11+
* distributed under the License is distributed on an "AS IS" BASIS,
12+
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
* See the License for the specific language governing permissions and
14+
* limitations under the License.
15+
*/
16+
package org.springframework.data.redis.connection.lettuce;
17+
18+
import static org.assertj.core.api.Assertions.*;
19+
20+
import io.lettuce.core.ReadFrom;
21+
import io.lettuce.core.RedisClient;
22+
import io.lettuce.core.RedisURI;
23+
import io.lettuce.core.codec.ByteArrayCodec;
24+
import io.lettuce.core.masterreplica.StatefulRedisMasterReplicaConnection;
25+
26+
import java.util.Collections;
27+
import java.util.concurrent.CompletionStage;
28+
import java.util.concurrent.ExecutionException;
29+
import java.util.concurrent.TimeUnit;
30+
import java.util.concurrent.TimeoutException;
31+
32+
import org.junit.jupiter.api.Test;
33+
import org.junit.jupiter.api.extension.ExtendWith;
34+
35+
import org.springframework.data.redis.SettingsUtils;
36+
import org.springframework.data.redis.test.extension.LettuceExtension;
37+
38+
/**
39+
* Integration test for {@link StaticMasterReplicaConnectionProvider}.
40+
*
41+
* @author Mark Paluch
42+
*/
43+
@ExtendWith(LettuceExtension.class)
44+
class StaticMasterReplicaConnectionProviderIntegrationTest {
45+
46+
RedisURI uri = RedisURI.create(SettingsUtils.getHost(), SettingsUtils.getPort());
47+
48+
@Test
49+
void shouldConnectToMasterReplicaSynchronously(RedisClient redisClient) {
50+
51+
StaticMasterReplicaConnectionProvider connectionProvider = new StaticMasterReplicaConnectionProvider(redisClient,
52+
ByteArrayCodec.INSTANCE, Collections.singletonList(uri), ReadFrom.REPLICA);
53+
54+
StatefulRedisMasterReplicaConnection<?, ?> connection = connectionProvider
55+
.getConnection(StatefulRedisMasterReplicaConnection.class);
56+
57+
assertThat(connection.getReadFrom()).isEqualTo(ReadFrom.REPLICA);
58+
59+
connectionProvider.release(connection);
60+
}
61+
62+
@Test
63+
@SuppressWarnings("rawtypes")
64+
void shouldConnectToMasterReplicaAsync(RedisClient redisClient)
65+
throws ExecutionException, InterruptedException, TimeoutException {
66+
67+
StaticMasterReplicaConnectionProvider connectionProvider = new StaticMasterReplicaConnectionProvider(redisClient,
68+
ByteArrayCodec.INSTANCE, Collections.singletonList(uri), ReadFrom.REPLICA);
69+
70+
CompletionStage<StatefulRedisMasterReplicaConnection> future = connectionProvider
71+
.getConnectionAsync(StatefulRedisMasterReplicaConnection.class);
72+
73+
StatefulRedisMasterReplicaConnection<?, ?> connection = future.toCompletableFuture().get(5, TimeUnit.SECONDS);
74+
assertThat(connection.getReadFrom()).isEqualTo(ReadFrom.REPLICA);
75+
76+
connectionProvider.release(connection);
77+
}
78+
}

0 commit comments

Comments
 (0)