Fix implementation of explicit refresh policy.
Original Pull Request #2908
Closes #2907
(cherry picked from commit 94a40a7a75)
This commit is contained in:
@@ -453,9 +453,7 @@ public class SimpleElasticsearchRepository<T, ID> implements ElasticsearchReposi
|
||||
|
||||
@Nullable
|
||||
public <R> R executeAndRefresh(OperationsCallback<R> callback, @Nullable RefreshPolicy refreshPolicy) {
|
||||
R result = callback.doWithOperations(operations.withRefreshPolicy(refreshPolicy));
|
||||
doRefresh();
|
||||
return result;
|
||||
return callback.doWithOperations(operations.withRefreshPolicy(refreshPolicy));
|
||||
}
|
||||
// endregion
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user