in src/main/java/com/ericsson/gerrit/plugins/highavailability/forwarder/ForwardedIndexChangeHandler.java [128:151]
private boolean rescheduleIndex(String id, Optional<IndexEvent> indexEvent, int retryCount) {
if (retryCount > maxTries) {
log.atSevere().log(
"Change %s could not be indexed after %d retries. Change index could be stale.",
id, retryCount);
return false;
}
log.atWarning().log(
"Retrying for the #%d time to index Change %s after %d msecs",
retryCount, id, retryInterval);
indexExecutor.schedule(
() -> {
try (ManualRequestContext ctx = oneOffCtx.open()) {
Context.setForwardedEvent(true);
doIndex(id, indexEvent, retryCount);
} catch (Exception e) {
log.atWarning().withCause(e).log("Change %s could not be indexed", id);
}
},
retryInterval,
TimeUnit.MILLISECONDS);
return true;
}