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

catch Exception rather than Throwable

This commit is contained in:
javanna 2016-06-10 11:39:08 +02:00 committed by Luca Cavanna
parent 9cbfa984fa
commit 432efc75fb
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
client-sniffer/src/main/java/org/elasticsearch/client/sniff/Sniffer.java
View File

@ -96,8 +96,8 @@ public final class Sniffer extends RestClient.FailureListener implements Closeab
} }
logger.debug("scheduling next sniff in " + delayMillis + " ms"); logger.debug("scheduling next sniff in " + delayMillis + " ms");
this.scheduledFuture = this.scheduledExecutorService.schedule(this, delayMillis, TimeUnit.MILLISECONDS); this.scheduledFuture = this.scheduledExecutorService.schedule(this, delayMillis, TimeUnit.MILLISECONDS);
} catch(Throwable t) { } catch(Exception e) {
logger.error("error while scheduling next sniffer task", t); logger.error("error while scheduling next sniffer task", e);
} }
} }
} }
@ -120,8 +120,8 @@ public final class Sniffer extends RestClient.FailureListener implements Closeab
} }
logger.debug("sniffed nodes: " + sniffedNodes); logger.debug("sniffed nodes: " + sniffedNodes);
this.restClient.setHosts(sniffedNodes.toArray(new HttpHost[sniffedNodes.size()])); this.restClient.setHosts(sniffedNodes.toArray(new HttpHost[sniffedNodes.size()]));
} catch (Throwable t) { } catch (Exception e) {
logger.error("error while sniffing nodes", t); logger.error("error while sniffing nodes", e);
} finally { } finally {
scheduleNextRun(nextSniffDelayMillis); scheduleNextRun(nextSniffDelayMillis);
running.set(false); running.set(false);