[james-project] 02/06: [REFACTORING] Add a missing ElasticSearch RequestOptions

[btellier]

This is an automated email from the ASF dual-hosted git repository.

btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git

commit 70b9ae4a4d243e60a7c18c000172721ed4fbc6c4
Author: Benoit Tellier <btell...@linagora.com>
AuthorDate: Thu Jan 16 09:55:11 2020 +0100

    [REFACTORING] Add a missing ElasticSearch RequestOptions
---
 .../main/java/org/apache/james/backends/es/DeleteByQueryPerformer.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/backends-common/elasticsearch/src/main/java/org/apache/james/backends/es/DeleteByQueryPerformer.java
 
b/backends-common/elasticsearch/src/main/java/org/apache/james/backends/es/DeleteByQueryPerformer.java
index f9ba528..66ad682 100644
--- 
a/backends-common/elasticsearch/src/main/java/org/apache/james/backends/es/DeleteByQueryPerformer.java
+++ 
b/backends-common/elasticsearch/src/main/java/org/apache/james/backends/es/DeleteByQueryPerformer.java
@@ -25,6 +25,7 @@ import org.elasticsearch.action.bulk.BulkResponse;
 import org.elasticsearch.action.delete.DeleteRequest;
 import org.elasticsearch.action.search.SearchRequest;
 import org.elasticsearch.action.search.SearchResponse;
+import org.elasticsearch.client.RequestOptions;
 import org.elasticsearch.client.RestHighLevelClient;
 import org.elasticsearch.common.unit.TimeValue;
 import org.elasticsearch.index.query.QueryBuilder;
@@ -83,6 +84,6 @@ public class DeleteByQueryPerformer {
                     .routing(routingKey.asString()));
         }
 
-        return Mono.fromCallable(() -> client.bulk(request));
+        return Mono.fromCallable(() -> client.bulk(request, 
RequestOptions.DEFAULT));
     }
 }


---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscr...@james.apache.org
For additional commands, e-mail: server-dev-h...@james.apache.org