Elasticsearch 7 rest client

.gitignore

@@ -9,6 +9,8 @@ release.properties
 *.iws
 .idea/
 out/
+build/
+**/buildOutputCleanup/
 
 # Eclipse
 .settings/

README.md

@@ -5,15 +5,15 @@ Dropwizard Elasticsearch
 [![Coverage Status](https://img.shields.io/coveralls/dropwizard/dropwizard-elasticsearch.svg)](https://coveralls.io/r/dropwizard/dropwizard-elasticsearch)
 [![Maven Central](https://img.shields.io/maven-central/v/io.dropwizard.modules/dropwizard-elasticsearch.svg)](http://mvnrepository.com/artifact/io.dropwizard.modules/dropwizard-elasticsearch)
 
-A set of classes for using [Elasticsearch][1] (version 2.3.0 and higher) in a [Dropwizard][2] application.
+A set of classes for using [Elasticsearch][1] (version 7.1.0 and higher) in a [Dropwizard][2] application.
 
 The package provides a [lifecycle-managed][3] client class (`ManagedEsClient`), a configuration class with the most
 common options (`EsConfiguration`), and some [health checks][4] which can instantly be used in any Dropwizard application.
 
 [1]: http://www.elasticsearch.org/
-[2]: http://dropwizard.io/1.2.0/docs
-[3]: http://dropwizard.io/1.2.0/docs/manual/core.html#managed-objects
-[4]: http://dropwizard.io/1.2.0/docs/manual/core.html#health-checks
+[2]: http://dropwizard.io/1.3.0/docs
+[3]: http://dropwizard.io/1.3.0/docs/manual/core.html#managed-objects
+[4]: http://dropwizard.io/1.3.0/docs/manual/core.html#health-checks
 
 
 Usage
@@ -43,33 +43,14 @@ Configuration
 
 The following configuration settings are supported by `EsConfiguration`:
 
-* `nodeClient`: When `true`, `ManagedEsClient` will create a `NodeClient`, otherwise a `TransportClient`; default: `true`
 * `servers`: A list of servers for usage with the created TransportClient if `nodeClient` is `false`
-* `clusterName`: The name of the Elasticsearch cluster; default: "elasticsearch"
-* `settings`: Any additional settings for Elasticsearch, see [Configuration](https://www.elastic.co/guide/en/elasticsearch/reference/2.4/setup-configuration.html)
-* `settingsFile`: Any additional settings file for Elasticsearch, see [Configuration](https://www.elastic.co/guide/en/elasticsearch/reference/2.4/setup-configuration.html)
 
-An example configuration file for creating a Node Client could like this:
+An example configuration file for creating a High Level Rest Client could like this:
 
-    clusterName: MyClusterName
-    settings:
-      node.name: MyCustomNodeName
-
-The order of precedence is: `nodeClient`/`servers`/`clusterName` > `settings` > `settingsFile`, meaning that
-any setting in `settingsFile` can be overwritten with `settings` which in turn get overwritten by the specific settings
-like `clusterName`.
-
-Maven Artifacts
----------------
-
-This project is available on Maven Central. To add it to your project simply add the following dependencies to your
-`pom.xml`:
-
-    <dependency>
-      <groupId>io.dropwizard.modules</groupId>
-      <artifactId>dropwizard-elasticsearch</artifactId>
-      <version>1.2.0-1</version>
-    </dependency>
+    servers:
+      - http://127.0.0.1:9200
+      - http://127.0.0.1:9201
+      - http://127.0.0.1:9202
 
 
 Support

pom.xml

@@ -8,7 +8,7 @@
 
     <groupId>io.dropwizard.modules</groupId>
     <artifactId>dropwizard-elasticsearch</artifactId>
-    <version>1.2.0-2-SNAPSHOT</version>
+    <version>1.3.0-1-SNAPSHOT</version>
     <packaging>jar</packaging>
 
     <name>Dropwizard Elasticsearch Bundle</name>
@@ -69,7 +69,7 @@
         <maven.compiler.source>1.8</maven.compiler.source>
         <maven.compiler.target>1.8</maven.compiler.target>
         <dropwizard.version>1.3.11</dropwizard.version>
-        <elasticsearch.version>2.4.6</elasticsearch.version>
+        <elasticsearch.version>7.1.0</elasticsearch.version>
     </properties>
 
     <dependencyManagement>
@@ -94,6 +94,12 @@
             <artifactId>elasticsearch</artifactId>
             <version>${elasticsearch.version}</version>
         </dependency>
+        <dependency>
+            <groupId>org.elasticsearch.client</groupId>
+            <artifactId>elasticsearch-rest-high-level-client</artifactId>
+            <version>7.1.0</version>
+        </dependency>
+
         <dependency>
             <groupId>junit</groupId>
             <artifactId>junit</artifactId>

src/main/java/io/dropwizard/elasticsearch/config/EsConfiguration.java

@@ -1,61 +1,37 @@
 package io.dropwizard.elasticsearch.config;
 
-import com.fasterxml.jackson.annotation.JsonIgnore;
 import com.fasterxml.jackson.annotation.JsonProperty;
-import com.google.common.net.HostAndPort;
-import io.dropwizard.validation.ValidationMethod;
-import org.hibernate.validator.constraints.NotEmpty;
 
-import javax.validation.constraints.NotNull;
+import org.apache.http.HttpHost;
+
+import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
-import java.util.Map;
+
+import javax.validation.constraints.NotNull;
 
 /**
  * Configuration class for Elasticsearch related settings.
  */
 public class EsConfiguration {
     @JsonProperty
     @NotNull
-    private List<HostAndPort> servers = Collections.emptyList();
-
-    @JsonProperty
-    @NotEmpty
-    private String clusterName = "elasticsearch";
-
-    @JsonProperty
-    private boolean nodeClient = true;
-
-    @JsonProperty
-    @NotNull
-    private Map<String, String> settings = Collections.emptyMap();
-
-    @JsonProperty
-    private String settingsFile = null;
+    private List<String> servers = Collections.emptyList();
 
-    public List<HostAndPort> getServers() {
+    public List<String> getServers() {
         return servers;
     }
 
-    public String getClusterName() {
-        return clusterName;
-    }
-
-    public boolean isNodeClient() {
-        return nodeClient;
+    public List<HttpHost> getServersAsHttpHosts() {
+        ArrayList<HttpHost> httpHosts=new ArrayList<>();
+        getServers().forEach(hostAndPort -> {
+            HttpHost httpHost = HttpHost.create(hostAndPort);
+            if (httpHost.getPort() < 0) {
+                httpHost = new HttpHost(httpHost.getHostName(), 9200);
+            }
+            httpHosts.add(httpHost);
+        });
+        return httpHosts;
     }
 
-    public Map<String, String> getSettings() {
-        return settings;
-    }
-
-    public String getSettingsFile() {
-        return settingsFile;
-    }
-
-    @ValidationMethod
-    @JsonIgnore
-    public boolean isValidConfig() {
-        return nodeClient || !servers.isEmpty();
-    }
 }

src/main/java/io/dropwizard/elasticsearch/health/EsClusterHealthCheck.java

@@ -1,7 +1,12 @@
 package io.dropwizard.elasticsearch.health;
 
 import com.codahale.metrics.health.HealthCheck;
+
+import org.elasticsearch.action.admin.cluster.health.ClusterHealthRequest;
+import org.elasticsearch.action.admin.cluster.health.ClusterHealthResponse;
 import org.elasticsearch.client.Client;
+import org.elasticsearch.client.RequestOptions;
+import org.elasticsearch.client.RestHighLevelClient;
 import org.elasticsearch.cluster.health.ClusterHealthStatus;
 
 import static com.google.common.base.Preconditions.checkNotNull;
@@ -12,7 +17,7 @@
  * @see <a href="http://www.elasticsearch.org/guide/reference/api/admin-cluster-health/">Admin Cluster Health</a>
  */
 public class EsClusterHealthCheck extends HealthCheck {
-    private final Client client;
+    private final RestHighLevelClient client;
     private final boolean failOnYellow;
 
     /**
@@ -21,7 +26,7 @@ public class EsClusterHealthCheck extends HealthCheck {
      * @param client       an Elasticsearch {@link Client} instance connected to the cluster
      * @param failOnYellow whether the health check should fail if the cluster health state is yellow
      */
-    public EsClusterHealthCheck(Client client, boolean failOnYellow) {
+    public EsClusterHealthCheck(RestHighLevelClient client, boolean failOnYellow) {
         this.client = checkNotNull(client);
         this.failOnYellow = failOnYellow;
     }
@@ -30,9 +35,9 @@ public EsClusterHealthCheck(Client client, boolean failOnYellow) {
      * Construct a new Elasticsearch cluster health check which will fail if the cluster health state is
      * {@link ClusterHealthStatus#RED}.
      *
-     * @param client an Elasticsearch {@link Client} instance connected to the cluster
+     * @param client an Elasticsearch {@link RestHighLevelClient} instance connected to the cluster
      */
-    public EsClusterHealthCheck(Client client) {
+    public EsClusterHealthCheck(RestHighLevelClient client) {
         this(client, false);
     }
 
@@ -47,7 +52,9 @@ public EsClusterHealthCheck(Client client) {
      */
     @Override
     protected Result check() throws Exception {
-        final ClusterHealthStatus status = client.admin().cluster().prepareHealth().get().getStatus();
+        ClusterHealthRequest request = new ClusterHealthRequest();
+        ClusterHealthResponse response = client.cluster().health(request, RequestOptions.DEFAULT);
+        final ClusterHealthStatus status = response.getStatus();
 
         if (status == ClusterHealthStatus.RED || (failOnYellow && status == ClusterHealthStatus.YELLOW)) {
             return Result.unhealthy("Last status: %s", status.name());