Merge pull request #7 from mesosphere/elastic-6.6

* Updated for ES 6.6.1

Author: mpereira

README.md

@@ -10,6 +10,7 @@ The data sent to the StatsD server tries to be roughly equivalent to the [Indice
 
 | Elasticsearch  | Plugin         | Release date |
 | -------------- | -------------- | ------------ |
+| 6.6.1          | 6.6.1.0        | Mar 11, 2019 |
 | 6.5.0          | 6.5.0.0        | Jan 2,  2019 |
 | 6.4.3          | 6.4.3.0        | Jan 1,  2019 |
 | 6.4.2          | 6.4.2.0        | Oct 10, 2018 |
@@ -84,12 +85,12 @@ The plugin artifacts are published to Maven Central and Github. To install a pre
 From Github:
 
 ```
-./bin/elasticsearch-plugin install https://github.com/Automattic/elasticsearch-statsd-plugin/releases/download/6.5.0.0/elasticsearch-statsd-6.5.0.0.zip
+./bin/elasticsearch-plugin install https://github.com/Automattic/elasticsearch-statsd-plugin/releases/download/6.6.1.0/elasticsearch-statsd-6.6.1.0.zip
 ```
 
 From Maven Central:
 ```
-./bin/elasticsearch-plugin install http://repo1.maven.org/maven2/com/automattic/elasticsearch-statsd/6.5.0.0/elasticsearch-statsd-6.5.0.0.zip
+./bin/elasticsearch-plugin install http://repo1.maven.org/maven2/com/automattic/elasticsearch-statsd/6.6.1.0/elasticsearch-statsd-6.6.1.0.zip
 ```
 
 Change the version to match your ES version. For ES `x.y.z` the version is `x.y.z.0`
@@ -105,7 +106,7 @@ mvn clean package -Djava.security.policy=src/test/resources/plugin-security-test
 Once we have the artifact, install it with the following command:
 
 ```
-bin/elasticsearch-plugin install file:///absolute/path/to/current/dir/target/releases/elasticsearch-statsd-6.5.0.0.zip
+bin/elasticsearch-plugin install file:///absolute/path/to/current/dir/target/releases/elasticsearch-statsd-6.6.1.0.zip
 ```
 
 ## Installation Elasticsearch 5.x

pom.xml

@@ -5,7 +5,7 @@
     <modelVersion>4.0.0</modelVersion>
     <groupId>com.automattic</groupId>
     <artifactId>elasticsearch-statsd</artifactId>
-    <version>6.5.0.0</version>
+    <version>6.6.1.0</version>
     <packaging>jar</packaging>
 
     <name>elasticsearch-statsd</name>
@@ -46,7 +46,7 @@
     </developers>
 
     <properties>
-        <elasticsearch.version>6.5.0</elasticsearch.version>
+        <elasticsearch.version>6.6.1</elasticsearch.version>
         <junit.version>4.12</junit.version>
         <maven.compiler.target>1.8</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

src/main/java/com/automattic/elasticsearch/statsd/StatsdService.java

@@ -1,5 +1,7 @@
 package com.automattic.elasticsearch.statsd;
 
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
 import com.automattic.elasticsearch.plugin.StatsdPlugin;
 import com.timgroup.statsd.NonBlockingStatsDClient;
 import com.timgroup.statsd.StatsDClient;
@@ -46,6 +48,8 @@ public class StatsdService extends AbstractLifecycleComponent {
     private final Thread statsdReporterThread;
     private final AtomicBoolean closed = new AtomicBoolean(false);
 
+    protected static final Logger logger = LogManager.getLogger(StatsdService.class);
+
     @Inject
     public StatsdService(Settings settings, Client client, ClusterService clusterService, IndicesService indicesService, NodeService nodeService) {
         super(settings);
@@ -75,7 +79,7 @@ public StatsdService(Settings settings, Client client, ClusterService clusterSer
                         StatsdService.this.statsdPort));
 
         this.statsdReporterThread = EsExecutors
-                .daemonThreadFactory(this.settings, "statsd_reporter")
+                .daemonThreadFactory(settings, "statsd_reporter")
                 .newThread(new StatsdReporterThread());
     }
 

src/test/java/com/automattic/elasticsearch/statsd/test/StatsdMockServer.java

@@ -1,7 +1,7 @@
 package com.automattic.elasticsearch.statsd.test;
 
+import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
-import org.elasticsearch.common.logging.Loggers;
 
 import java.io.BufferedReader;
 import java.io.ByteArrayInputStream;
@@ -18,7 +18,7 @@ public class StatsdMockServer extends Thread {
     public Collection<String> content = new ArrayList<>();
     private DatagramSocket socket;
     private boolean isClosed = false;
-    private final Logger logger = Loggers.getLogger(getClass());
+    protected static final Logger logger = LogManager.getLogger(StatsdMockServer.class);
 
     public StatsdMockServer(int port) {
         this.port = port;