Add content-type header to support ElasticSearch 6.1.0

Author: Robin Duda

pom.xml

@@ -10,7 +10,7 @@
 
     <groupId>com.codingchili</groupId>
     <artifactId>excelastic</artifactId>
-    <version>1.2.4</version>
+    <version>1.2.5</version>
     <build>
         <plugins>
             <plugin>

src/main/java/com/codingchili/ApplicationLauncher.java

@@ -29,7 +29,7 @@
 public class ApplicationLauncher {
     private static final Logger logger = Logger.getLogger(ApplicationLauncher.class.getName());
     public static final String PARAM_CLEAR = "--clear";
-    public static String VERSION = "1.2.4";
+    public static String VERSION = "1.2.5";
     private Vertx vertx = Vertx.vertx();
     private String[] args;
 

src/main/java/com/codingchili/Model/ElasticWriter.java

@@ -1,6 +1,7 @@
 package com.codingchili.Model;
 
 import io.netty.handler.codec.http.HttpHeaderNames;
+import io.netty.handler.codec.http.HttpHeaderValues;
 import io.vertx.core.AbstractVerticle;
 import io.vertx.core.AsyncResult;
 import io.vertx.core.Context;
@@ -125,13 +126,18 @@ private HttpClientRequest post(String path) {
         HttpClientRequest client = vertx.createHttpClient()
                 .post(Configuration.getElasticPort(), Configuration.getElasticHost(), path);
 
-        addSecurityHeaders(client);
+        addHeaders(client);
         return client;
     }
 
-    private void addSecurityHeaders(HttpClientRequest request) {
+    private void addHeaders(HttpClientRequest client) {
+
+        // comply with ElasticSearch 6.0 - strict content type.
+        client.putHeader(HttpHeaderNames.CONTENT_TYPE, HttpHeaderValues.APPLICATION_JSON);
+
+        // support basic authentication.
         Configuration.getBasicAuth().ifPresent(auth -> {
-            request.putHeader(HttpHeaderNames.AUTHORIZATION, "Basic " + auth);
+            client.putHeader(HttpHeaderNames.AUTHORIZATION, "Basic " + auth);
         });
     }
 
@@ -182,13 +188,13 @@ private void pollElasticServer(Long id) {
 
     private HttpClientRequest get(String path) {
         HttpClientRequest request = vertx.createHttpClient().get(Configuration.getElasticPort(), Configuration.getElasticHost(), path);
-        addSecurityHeaders(request);
+        addHeaders(request);
         return request;
     }
 
     private HttpClientRequest delete(String path) {
         HttpClientRequest request = vertx.createHttpClient().delete(Configuration.getElasticPort(), Configuration.getElasticHost(), path);
-        addSecurityHeaders(request);
+        addHeaders(request);
         return request;
     }