From 65a5944824833aa8824d692589e24f1885a34cb2 Mon Sep 17 00:00:00 2001
From: luoquan <hellolq2008@163.com>
Date: Tue, 1 Nov 2016 10:35:22 +0800
Subject: [PATCH] fix 'socket closed' problem

---
 .../plugin/synonym/analysis/RemoteSynonymFile.java | 14 +++++++++-----
 1 file changed, 9 insertions(+), 5 deletions(-)

diff --git a/src/main/java/com/bellszhu/elasticsearch/plugin/synonym/analysis/RemoteSynonymFile.java b/src/main/java/com/bellszhu/elasticsearch/plugin/synonym/analysis/RemoteSynonymFile.java
index de4eafe..ebd6edb 100644
--- a/src/main/java/com/bellszhu/elasticsearch/plugin/synonym/analysis/RemoteSynonymFile.java
+++ b/src/main/java/com/bellszhu/elasticsearch/plugin/synonym/analysis/RemoteSynonymFile.java
@@ -62,9 +62,10 @@ public RemoteSynonymFile(Environment env, Analyzer analyzer,
 
 	@Override
 	public SynonymMap reloadSynonymMap() {
+	    Reader rulesReader = null;
 		try {
 			logger.info("start reload remote synonym from {}.", location);
-			Reader rulesReader = getReader();
+			rulesReader = getReader();
 			SynonymMap.Builder parser = null;
 
 			if ("wordnet".equalsIgnoreCase(format)) {
@@ -80,7 +81,13 @@ public SynonymMap reloadSynonymMap() {
 			throw new IllegalArgumentException(
 					"could not reload remote synonyms file to build synonyms",
 					e);
-		}
+		} finally {
+            try {
+                rulesReader.close();
+            } catch(Exception e) {
+                e.printStackTrace();
+            }
+        }
 	}
 
 	/**
@@ -129,9 +136,6 @@ public Reader getReader() {
 					"IOException while reading remote synonyms file", e);
 		} finally {
 			try {
-				if (response != null) {
-					response.close();
-				}
 				if (br != null) {
 					br.close();
 				}