switched to RequestOptions from Headers

elastic · Jun 7, 2018 · 53b0747 · 53b0747
1 parent 7bcc283
commit 53b0747
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git a/client/rest-high-level/src/main/java/org/elasticsearch/client/IndicesClient.java b/client/rest-high-level/src/main/java/org/elasticsearch/client/IndicesClient.java
@@ -1068,9 +1068,9 @@ public void putTemplateAsync(PutIndexTemplateRequest putIndexTemplateRequest, Re
      * See <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/search-validate.html"> Validate Query API
      * on elastic.co</a>
      */
-    public ValidateQueryResponse validateQuery(ValidateQueryRequest validateQueryRequest, Header... headers) throws IOException {
-        return restHighLevelClient.performRequestAndParseEntity(validateQueryRequest, RequestConverters::validateQuery,
-            ValidateQueryResponse::fromXContent, emptySet(), headers);
+    public ValidateQueryResponse validateQuery(ValidateQueryRequest validateQueryRequest, RequestOptions options) throws IOException {
+        return restHighLevelClient.performRequestAndParseEntity(validateQueryRequest, RequestConverters::validateQuery, options,
+            ValidateQueryResponse::fromXContent, emptySet());
     }
 
     /**
@@ -1079,9 +1079,9 @@ public ValidateQueryResponse validateQuery(ValidateQueryRequest validateQueryReq
      * See <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/search-validate.html"> Validate Query API
      * on elastic.co</a>
      */
-    public void validateQueryAsync(ValidateQueryRequest validateQueryRequest,
-                                   ActionListener<ValidateQueryResponse> listener, Header... headers) {
-        restHighLevelClient.performRequestAsyncAndParseEntity(validateQueryRequest, RequestConverters::validateQuery,
-            ValidateQueryResponse::fromXContent, listener, emptySet(), headers);
+    public void validateQueryAsync(ValidateQueryRequest validateQueryRequest, RequestOptions options,
+                                   ActionListener<ValidateQueryResponse> listener) {
+        restHighLevelClient.performRequestAsyncAndParseEntity(validateQueryRequest, RequestConverters::validateQuery, options,
+            ValidateQueryResponse::fromXContent, listener, emptySet());
     }
 }
diff --git a/...el/src/test/java/org/elasticsearch/client/documentation/IndicesClientDocumentationIT.java b/...el/src/test/java/org/elasticsearch/client/documentation/IndicesClientDocumentationIT.java
@@ -2019,7 +2019,7 @@ public void testValidateQuery() throws IOException, InterruptedException {
         // end::validate-query-request-rewrite
 
         // tag::validate-query-execute
-        ValidateQueryResponse response = client.indices().validateQuery(request); // <1>
+        ValidateQueryResponse response = client.indices().validateQuery(request, RequestOptions.DEFAULT); // <1>
         // end::validate-query-execute
 
         // tag::validate-query-response
@@ -2061,7 +2061,7 @@ public void onFailure(Exception e) {
         listener = new LatchedActionListener<>(listener, latch);
 
         // tag::validate-query-execute-async
-        client.indices().validateQueryAsync(request, listener); // <1>
+        client.indices().validateQueryAsync(request, RequestOptions.DEFAULT, listener); // <1>
         // end::validate-query-execute-async
 
         assertTrue(latch.await(30L, TimeUnit.SECONDS));