Merge branch 'master' into fixHeaderSplit

Author: anthonygauthier

README.md

@@ -32,13 +32,9 @@ JMeter ElasticSearch Backend Listener is a JMeter plugin enabling you to send te
 <dependency>
   <groupId>io.github.delirius325</groupId>
   <artifactId>jmeter.backendlistener.elasticsearch</artifactId>
-  <version>2.6.1</version>
-</dependency>
+  <version>2.6.2</version>
 ```
 
-### Supporting the author
-[![patreon](https://c5.patreon.com/external/logo/become_a_patron_button.png)](https://www.patreon.com/bePatron?u=17797269)
-
 ## Contributing
 Feel free to contribute by branching and making pull requests, or simply by suggesting ideas through the "Issues" tab.
 

pom.xml

@@ -3,7 +3,7 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>io.github.delirius325</groupId>
 	<artifactId>jmeter.backendlistener.elasticsearch</artifactId>
-	<version>2.6.1-patch</version>
+  <version>2.6.4-SNAPSHOT</version>
 	<packaging>jar</packaging>
 
 	<name>jmeter.backendlistener.elasticsearch</name>
@@ -124,7 +124,7 @@
 		<dependency>
 			<groupId>com.fasterxml.jackson.core</groupId>
 			<artifactId>jackson-databind</artifactId>
-			<version>2.8.11.3</version>
+			<version>[2.9.9,)</version>
 		</dependency>
 		<dependency>
 			<groupId>com.amazonaws</groupId>

src/main/java/io/github/delirius325/jmeter/backendlistener/elasticsearch/ElasticSearchMetricSender.java

@@ -79,9 +79,9 @@ public void createIndex() {
      * All is being sent through the low-level ElasticSearch REST Client.
      */
     public void sendRequest() {
-        Request request = new Request("POST", "/" + this.esIndex + "/SampleResult/_bulk");
+        Request request = new Request("POST", "/" + this.esIndex + "/_bulk");
         StringBuilder bulkRequestBody = new StringBuilder();
-        String actionMetaData = String.format(SEND_BULK_REQUEST, this.esIndex, "SampleResult");
+        String actionMetaData = String.format(SEND_BULK_REQUEST, this.esIndex);
 
         for (String metric : this.metricList) {
             bulkRequestBody.append(actionMetaData);

src/main/java/io/github/delirius325/jmeter/backendlistener/elasticsearch/ElasticSearchRequests.java

@@ -4,5 +4,5 @@ public class ElasticSearchRequests {
     /**
      * Request to send metrics (JMeter/Percentiles) as ElasticSearch documents
      */
-    public static String SEND_BULK_REQUEST = "{ \"index\" : { \"_index\" : \"%s\", \"_type\" : \"%s\" } }%n";
+    public static String SEND_BULK_REQUEST = "{ \"index\" : { \"_index\" : \"%s\" } }%n";
 }

src/main/java/io/github/delirius325/jmeter/backendlistener/elasticsearch/ElasticsearchBackendClient.java

@@ -7,6 +7,7 @@
 import org.apache.jmeter.samplers.SampleResult;
 import org.apache.jmeter.util.JMeterUtils;
 import org.apache.jmeter.visualizers.backend.AbstractBackendListenerClient;
+import org.apache.jmeter.visualizers.backend.BackendListener;
 import org.apache.jmeter.visualizers.backend.BackendListenerContext;
 import org.elasticsearch.client.Node;
 import org.elasticsearch.client.RestClient;
@@ -44,6 +45,24 @@ public class ElasticsearchBackendClient extends AbstractBackendListenerClient {
     private static RestClient client;
     private static final Logger logger = LoggerFactory.getLogger(ElasticsearchBackendClient.class);
     private static final AWSCredentialsProvider credentialsProvider = new DefaultAWSCredentialsProviderChain();
+    private static final Map<String, String> DEFAULT_ARGS = new LinkedHashMap<>();
+    static {
+        DEFAULT_ARGS.put(ES_SCHEME, "http");
+        DEFAULT_ARGS.put(ES_HOST, null);
+        DEFAULT_ARGS.put(ES_PORT, "9200");
+        DEFAULT_ARGS.put(ES_INDEX, null);
+        DEFAULT_ARGS.put(ES_TIMESTAMP, "yyyy-MM-dd'T'HH:mm:ss.SSSZZ");
+        DEFAULT_ARGS.put(ES_BULK_SIZE, "100");
+        DEFAULT_ARGS.put(ES_TIMEOUT_MS, Long.toString(DEFAULT_TIMEOUT_MS));
+        DEFAULT_ARGS.put(ES_SAMPLE_FILTER, null);
+        DEFAULT_ARGS.put(ES_TEST_MODE, "info");
+        DEFAULT_ARGS.put(ES_AUTH_USER, "");
+        DEFAULT_ARGS.put(ES_AUTH_PWD, "");
+        DEFAULT_ARGS.put(ES_PARSE_REQ_HEADERS, "false");
+        DEFAULT_ARGS.put(ES_PARSE_RES_HEADERS, "false");
+        DEFAULT_ARGS.put(ES_AWS_ENDPOINT,  "");
+        DEFAULT_ARGS.put(ES_AWS_REGION, "");
+    }
 
     private ElasticSearchMetricSender sender;
     private Set<String> modes;
@@ -52,25 +71,15 @@ public class ElasticsearchBackendClient extends AbstractBackendListenerClient {
     private int bulkSize;
     private long timeoutMs;
 
+    public ElasticsearchBackendClient() {
+        super();
+    }
+
     @Override
     public Arguments getDefaultParameters() {
-        Arguments parameters = new Arguments();
-        parameters.addArgument(ES_SCHEME, "http");
-        parameters.addArgument(ES_HOST, null);
-        parameters.addArgument(ES_PORT, "9200");
-        parameters.addArgument(ES_INDEX, null);
-        parameters.addArgument(ES_TIMESTAMP, "yyyy-MM-dd'T'HH:mm:ss.SSSZZ");
-        parameters.addArgument(ES_BULK_SIZE, "100");
-        parameters.addArgument(ES_TIMEOUT_MS, Long.toString(DEFAULT_TIMEOUT_MS));
-        parameters.addArgument(ES_SAMPLE_FILTER, null);
-        parameters.addArgument(ES_TEST_MODE, "info");
-        parameters.addArgument(ES_AUTH_USER, "");
-        parameters.addArgument(ES_AUTH_PWD, "");
-        parameters.addArgument(ES_PARSE_REQ_HEADERS, "false");
-        parameters.addArgument(ES_PARSE_RES_HEADERS, "false");
-        parameters.addArgument(ES_AWS_ENDPOINT,  "");
-        parameters.addArgument(ES_AWS_REGION, "");
-        return parameters;
+        Arguments arguments = new Arguments();
+        DEFAULT_ARGS.forEach(arguments::addArgument);
+        return arguments;
     }
 
     @Override
@@ -95,7 +104,6 @@ public void onFailure(Node node) {
                         .setMaxRetryTimeoutMillis(60000)
                         .build();
             } else {
-
                 AWS4Signer signer = new AWS4Signer();
                 signer.setServiceName(SERVICE_NAME);
                 signer.setRegionName(context.getParameter(ES_AWS_REGION));
@@ -106,7 +114,7 @@ public void onFailure(Node node) {
             this.sender.createIndex();
 
             checkTestMode(context.getParameter(ES_TEST_MODE));
-            
+
             String[] filterArray = (context.getParameter(ES_SAMPLE_FILTER).contains(";")) ? context.getParameter(ES_SAMPLE_FILTER).split(";") : new String[] {context.getParameter(ES_SAMPLE_FILTER)};
             if(filterArray.length > 0 && !filterArray[0].trim().equals("")) {
                 for (String filter : filterArray) {