15
15
import org .elasticsearch .client .RequestOptions ;
16
16
import org .elasticsearch .client .Response ;
17
17
import org .elasticsearch .client .RestClient ;
18
- import org .json .simple .JSONObject ;
19
- import org .json .simple .parser .JSONParser ;
18
+ import org .json .JSONObject ;
20
19
import org .slf4j .Logger ;
21
20
import org .slf4j .LoggerFactory ;
22
21
@@ -108,12 +107,11 @@ public int getElasticSearchVersion() {
108
107
logger .error ("Unable to perform request to ElasticSearch engine" , this .esIndex );
109
108
}else {
110
109
String responseBody = EntityUtils .toString (response .getEntity ());
111
- JSONParser parser = new JSONParser ();
112
- JSONObject elasticSearchConfig = (JSONObject ) parser .parse (responseBody );
113
- JSONObject version = (JSONObject )elasticSearchConfig .get ("version" );
110
+ JSONObject elasticSearchConfig = new JSONObject (responseBody );
111
+ JSONObject version = (JSONObject ) elasticSearchConfig .get ("version" );
114
112
String elasticVersion = version .get ("number" ).toString ();
115
113
elasticSearchVersion = Integer .parseInt (elasticVersion .split ("\\ ." )[0 ]);
116
-
114
+ logger . info ( "ElasticSearch Version : " + Integer . toString ( elasticSearchVersion ));
117
115
}
118
116
} catch (Exception e ) {
119
117
if (logger .isErrorEnabled ()) {
@@ -130,7 +128,6 @@ public int getElasticSearchVersion() {
130
128
* sent through the low-level ElasticSearch REST Client.
131
129
*/
132
130
public void sendRequest (int elasticSearchVersionPrefix ) {
133
- logger .info ("Elastic Search version : " + Integer .toString (elasticSearchVersionPrefix ));
134
131
Request request ;
135
132
StringBuilder bulkRequestBody = new StringBuilder ();
136
133
String actionMetaData ;
0 commit comments