Use custom refresh policy in reactive repository with all clients.

Original Pull Request #2350 Closes #2349
spring-projects · Nov 3, 2022 · 049bcf5 · 049bcf5
1 parent 744b3ed
commit 049bcf5
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...ramework/data/elasticsearch/repository/support/SimpleReactiveElasticsearchRepository.java b/...ramework/data/elasticsearch/repository/support/SimpleReactiveElasticsearchRepository.java
@@ -22,7 +22,7 @@
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.domain.Sort;
 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.ReactiveElasticsearchOperations;
 import org.springframework.data.elasticsearch.core.ReactiveIndexOperations;
@@ -245,8 +245,8 @@ private String convertId(Object id) {
 	private Mono<Void> doRefresh() {
 		RefreshPolicy refreshPolicy = null;
 
-		if (operations instanceof ReactiveElasticsearchTemplate) {
-			refreshPolicy = ((ReactiveElasticsearchTemplate) operations).getRefreshPolicy();
+		if (operations instanceof AbstractReactiveElasticsearchTemplate template) {
+			refreshPolicy = template.getRefreshPolicy();
 		}
 
 		if (refreshPolicy == null) {