Cwikius-Spring/spring-data-elasticsearch
1
0
Fork 0
mirror of https://github.com/spring-projects/spring-data-elasticsearch.git synced 2025-06-15 16:42:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use custom refresh policy in reactive repository with all clients.

Browse Source 
Original Pull Request #2350
Closes #2349
This commit is contained in:
Peter-Josef Meisch 2022-11-03 19:49:48 +01:00 committed by GitHub
parent 744b3ed6b4
commit 049bcf504e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/springframework/data/elasticsearch/repository/support/SimpleReactiveElasticsearchRepository.java
View File

@ -22,7 +22,7 @@ import org.reactivestreams.Publisher;
import org.springframework.data.domain.Pageable; import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort; import org.springframework.data.domain.Sort;
import org.springframework.data.elasticsearch.client.erhlc.NativeSearchQueryBuilder; import org.springframework.data.elasticsearch.client.erhlc.NativeSearchQueryBuilder;
import org.springframework.data.elasticsearch.client.erhlc.ReactiveElasticsearchTemplate; import org.springframework.data.elasticsearch.core.AbstractReactiveElasticsearchTemplate;
import org.springframework.data.elasticsearch.core.MultiGetItem; import org.springframework.data.elasticsearch.core.MultiGetItem;
import org.springframework.data.elasticsearch.core.ReactiveElasticsearchOperations; import org.springframework.data.elasticsearch.core.ReactiveElasticsearchOperations;
import org.springframework.data.elasticsearch.core.ReactiveIndexOperations; import org.springframework.data.elasticsearch.core.ReactiveIndexOperations;
@ -245,8 +245,8 @@ public class SimpleReactiveElasticsearchRepository<T, ID> implements ReactiveEla
private Mono<Void> doRefresh() { private Mono<Void> doRefresh() {
RefreshPolicy refreshPolicy = null; RefreshPolicy refreshPolicy = null;
if (operations instanceof ReactiveElasticsearchTemplate) { if (operations instanceof AbstractReactiveElasticsearchTemplate template) {
refreshPolicy = ((ReactiveElasticsearchTemplate) operations).getRefreshPolicy(); refreshPolicy = template.getRefreshPolicy();
} }
if (refreshPolicy == null) { if (refreshPolicy == null) {