Revert "Move to elasticsearch-java 8. Removed the use of RestHighLeve…

…lClient and xcontent (#320)"

This reverts commit 48e0b0c.

elasticsearch/build.gradle

@@ -4,6 +4,7 @@ plugins {
 
 dependencies {
     annotationProcessor mn.micronaut.graal
+    api "org.elasticsearch.client:elasticsearch-rest-high-level-client:$elasticsearchVersion"
     api "co.elastic.clients:elasticsearch-java:$elasticsearchVersion"
     api mn.micronaut.http
     api mn.micronaut.validation

elasticsearch/src/main/java/io/micronaut/elasticsearch/DefaultElasticsearchClientFactory.java

@@ -25,6 +25,7 @@
 
 import org.elasticsearch.client.RestClient;
 import org.elasticsearch.client.RestClientBuilder;
+import org.elasticsearch.client.RestHighLevelClient;
 
 import co.elastic.clients.elasticsearch.ElasticsearchAsyncClient;
 import co.elastic.clients.elasticsearch.ElasticsearchClient;
@@ -43,6 +44,17 @@
 @Factory
 public class DefaultElasticsearchClientFactory {
 
+    /**
+     * Create the {@link RestHighLevelClient} bean for the given configuration.
+     *
+     * @param elasticsearchConfiguration The {@link DefaultElasticsearchConfigurationProperties} object
+     * @return A {@link RestHighLevelClient} bean
+     */
+    @Bean(preDestroy = "close")
+    RestHighLevelClient restHighLevelClient(DefaultElasticsearchConfigurationProperties elasticsearchConfiguration) {
+        return new RestHighLevelClient(restClientBuilder(elasticsearchConfiguration));
+    }
+
     /**
      * @param elasticsearchConfiguration The {@link DefaultElasticsearchConfigurationProperties} object
      * @return The Elasticsearch Rest Client

elasticsearch/src/main/java/io/micronaut/elasticsearch/DefaultHttpAsyncClientBuilderFactory.java

@@ -19,17 +19,17 @@
 import io.micronaut.context.annotation.Factory;
 import io.micronaut.context.annotation.Requires;
 import org.apache.http.impl.nio.client.HttpAsyncClientBuilder;
+import org.elasticsearch.client.RestHighLevelClient;
 
 import jakarta.inject.Singleton;
-import org.elasticsearch.client.RestClient;
 
 /**
  * The default factory used to create {@link HttpAsyncClientBuilder} for HTTP client configurations.
  *
  * @author Puneet Behl
  * @since 1.0.0
  */
-@Requires(classes = {RestClient.class})
+@Requires(classes = {RestHighLevelClient.class})
 @Factory
 public class DefaultHttpAsyncClientBuilderFactory {
 

elasticsearch/src/main/java/io/micronaut/elasticsearch/conditon/RequiresElasticsearch.java

@@ -17,7 +17,7 @@
 
 import io.micronaut.elasticsearch.ElasticsearchSettings;
 import io.micronaut.context.annotation.Requires;
-import org.elasticsearch.client.RestClient;
+import org.elasticsearch.client.RestHighLevelClient;
 
 import java.lang.annotation.*;
 
@@ -31,6 +31,6 @@
 @Retention(RetentionPolicy.RUNTIME)
 @Target({ElementType.PACKAGE, ElementType.TYPE})
 @Requires(property = ElasticsearchSettings.PREFIX)
-@Requires(classes = {RestClient.class})
+@Requires(classes = {RestHighLevelClient.class})
 public @interface RequiresElasticsearch {
 }

elasticsearch/src/main/java/io/micronaut/elasticsearch/graalvm/RestClientSubstitutions.java

@@ -47,7 +47,7 @@
  *
  * We substitute it with an implementation which does not use serialization.
  *
- * Forked from Quarkus: https://github.com/quarkusio/quarkus/blob/main/extensions/elasticsearch-rest-client-common/runtime/src/main/java/io/quarkus/elasticsearch/restclient/common/runtime/graal/Substitute_RestClient.java
+ * Forked from Quarkus: https://github.com/quarkusio/quarkus/blob/c9cba824e8812fa3f15474b8382ac5d90f7238aa/extensions/elasticsearch-rest-client/runtime/src/main/java/io/quarkus/elasticsearch/restclient/runtime/graal/Substitute_RestClient.java
  *
  * @author Iván López
  * @since 2.0.0
@@ -109,7 +109,7 @@ public NoSerializationBasicAuthCache() {
             this(null);
         }
 
-        private HttpHost getKey(final HttpHost host) {
+        protected HttpHost getKey(final HttpHost host) {
             if (host.getPort() <= 0) {
                 final int port;
                 try {