Catch EsRejectedExecException on cluster info reschedule

This commit is contained in:
Simon Willnauer 2013-09-30 16:03:26 +02:00
parent 9787562d27
commit 8b69035fa0
1 changed files with 5 additions and 1 deletions

View File

@ -237,7 +237,11 @@ public final class InternalClusterInfoService extends AbstractComponent implemen
if (logger.isTraceEnabled()) {
logger.trace("Scheduling next run for updating cluster info in: {}", updateFrequency.toString());
}
threadPool.schedule(updateFrequency, executorName(), new SubmitReschedulingClusterInfoUpdatedJob());
try {
threadPool.schedule(updateFrequency, executorName(), new SubmitReschedulingClusterInfoUpdatedJob());
} catch (EsRejectedExecutionException ex) {
logger.debug("Reschedule cluster info service was rejected", ex);
}
}
if (!enabled) {
// Short-circuit if not enabled