From df485dafa4d2b358148dae036e011321732707f1 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=9F=B3=E6=BA=90?= <shiyuan_90@163.com>
Date: Tue, 24 Apr 2018 10:14:57 +0800
Subject: [PATCH] es 5.6.9 support

---
 pom.xml                                                       | 4 ++--
 .../org/ansj/elasticsearch/action/TransportAnsjAction.java    | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/pom.xml b/pom.xml
index 4ef762a..33c70de 100644
--- a/pom.xml
+++ b/pom.xml
@@ -4,7 +4,7 @@
 
 	<groupId>org.ansj</groupId>
 	<artifactId>elasticsearch-analysis-ansj</artifactId>
-	<version>5.6.8.0</version>
+	<version>5.6.9.0</version>
 	<description>elasticsearch analysis by ansj</description>
 	<name>elasticsearch-analysis-ansj</name>
 	<url>http://maven.nlpcn.org</url>
@@ -21,7 +21,7 @@
 		<runSuite>**/MainTestSuite.class</runSuite>
 		<elasticsearch.plugin.name>elasticsearch-analysis-ansj</elasticsearch.plugin.name>
         <elasticsearch.plugin.java.version>1.8</elasticsearch.plugin.java.version>
-		<elasticsearch.version>5.6.8</elasticsearch.version>
+		<elasticsearch.version>5.6.9</elasticsearch.version>
 		<elasticsearch.plugin.classname>org.ansj.elasticsearch.plugin.AnalysisAnsjPlugin</elasticsearch.plugin.classname>
 	</properties>
 
diff --git a/src/main/java/org/ansj/elasticsearch/action/TransportAnsjAction.java b/src/main/java/org/ansj/elasticsearch/action/TransportAnsjAction.java
index 868a404..e4d1c29 100644
--- a/src/main/java/org/ansj/elasticsearch/action/TransportAnsjAction.java
+++ b/src/main/java/org/ansj/elasticsearch/action/TransportAnsjAction.java
@@ -315,15 +315,15 @@ public AnsjResponse newInstance() {
                 @Override
                 public void handleResponse(AnsjResponse response) {
                     LOG.info("[{}] response: {}", node, response.asMap());
-                    countDownLatch.countDown();
                     result.put(node.getAddress().toString(), "success");
+                    countDownLatch.countDown();
                 }
 
                 @Override
                 public void handleException(TransportException exp) {
                     LOG.warn("failed to send request[path:{},args:{}] to [{}]: {}", req.getPath(), req.asMap(), node, exp);
-                    countDownLatch.countDown();
                     result.put(node.getAddress().toString(), "err :" + exp.getMessage());
+                    countDownLatch.countDown();
                 }
 
                 @Override