Also ignore rejected execution exception when retying restart

This commit is contained in:
Martijn van Groningen 2016-01-07 15:21:21 +01:00
parent 1ea690e814
commit c44b83dc29
1 changed files with 7 additions and 3 deletions

View File

@ -208,9 +208,13 @@ public class IngestBootstrapper extends AbstractLifecycleComponent implements Cl
installIngestIndexTemplate();
}
pipelineStore.start();
} catch (Exception e) {
logger.warn("pipeline store failed to start, retrying...", e);
startPipelineStore(metaData);
} catch (Exception e1) {
logger.warn("pipeline store failed to start, retrying...", e1);
try {
startPipelineStore(metaData);
} catch (RejectedExecutionException e2) {
logger.debug("async pipeline store start retry failed", e2);
}
}
});
} catch (RejectedExecutionException e) {