honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

use Closeables

This commit is contained in:
kimchy 2010-12-30 12:29:54 +02:00
parent 4f8b4b405c
commit abe33d59a5
1 changed files with 3 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
plugins/river/couchdb/src/main/java/org/elasticsearch/river/couchdb/CouchdbRiver.java
View File

@ -28,6 +28,7 @@ import org.elasticsearch.cluster.block.ClusterBlockException;
import org.elasticsearch.common.Base64;
import org.elasticsearch.common.collect.Maps;
import org.elasticsearch.common.inject.Inject;
import org.elasticsearch.common.io.Closeables;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.util.concurrent.EsExecutors;
import org.elasticsearch.common.util.concurrent.jsr166y.LinkedTransferQueue;
@ -374,15 +375,7 @@ public class CouchdbRiver extends AbstractRiverComponent implements River {
stream.add(line);
}
} catch (Exception e) {
if (is != null) {
try {
is.close();
} catch (IOException e1) {
// ignore
} finally {
is = null;
}
}
Closeables.closeQuietly(is);
if (connection != null) {
try {
connection.disconnect();
@ -404,15 +397,7 @@ public class CouchdbRiver extends AbstractRiverComponent implements River {
}
}
} finally {
if (is != null) {
try {
is.close();
} catch (IOException e1) {
// ignore
} finally {
is = null;
}
}
Closeables.closeQuietly(is);
if (connection != null) {
try {
connection.disconnect();