Spring/spring-data-redis
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Correctly return connection future from StaticMasterReplicaConnectionProvider.

Browse Source 
We now pass on the connection future when connecting through StaticMasterReplicaConnectionProvider.getConnectionAsync(…).

Closes #2296
This commit is contained in:
Mark Paluch
2022-04-06 14:21:46 +02:00
parent fea6e7842b
commit e0f49370d9
2 changed files with 81 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -90,10 +90,10 @@ class StaticMasterReplicaConnectionProvider implements LettuceConnectionProvider
CompletableFuture<? extends StatefulRedisMasterReplicaConnection<?, ?>> connection = MasterReplica
.connectAsync(client, codec, nodes);
connection.thenApply(it -> {
return connection.thenApply(it -> {
readFrom.ifPresent(readFrom -> it.setReadFrom(readFrom));
return connectionType.cast(connection);
readFrom.ifPresent(it::setReadFrom);
return connectionType.cast(it);
});
}