lee/heritrix3
1
0
Fork 0
mirror of https://github.com/internetarchive/heritrix3.git synced 2026-09-21 13:16:03 +00:00
Code Issues Packages Projects Releases Wiki Activity

close the rethinkdb connection!

Browse Source
This commit is contained in:
Noah Levitt
2019-04-10 10:43:22 -07:00
parent fc16e4ec3e
commit 303ffb486e
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
contrib/src/main/java/org/archive/trough/TroughClient.java
+6 -1
View File
@@ -182,6 +182,7 @@ public class TroughClient {
Exception lastE = null;
for (int i = 0; i <= retries; i++) {
int whichServer = rand.nextInt(rethinkServers.length);
Connection conn = null;
try {
String[] hostPort = rethinkServers[whichServer].split(":", 2);
String host = hostPort[0];
@@ -189,12 +190,16 @@ public class TroughClient {
if (hostPort.length == 2) {
port = Integer.valueOf(hostPort[1]);
}
Connection conn = r.connection().hostname(host).port(port).db(rethinkDb).connect();
conn = r.connection().hostname(host).port(port).db(rethinkDb).connect();
Object result = reql.run(conn);
return result;
} catch (Exception e) {
logger.warning("rethinkdb query failed (server=" + rethinkServers[whichServer] + "; " + i + " retries left)");
lastE = e;
} finally {
if (conn != null) {
conn.close();
}
}
}