in priam/src/main/java/com/netflix/priam/utils/RetryableCallable.java [47:69]
public T call() throws Exception {
int retry = 0;
int logCounter = 0;
while (true) {
try {
return retriableCall();
} catch (CancellationException e) {
throw e;
} catch (Exception e) {
retry++;
if (retry == retrys) {
throw e;
}
logger.error("Retry #{} for: {}", retry, e.getMessage());
if (++logCounter == 1 && logger.isErrorEnabled())
logger.error("Exception --> " + ExceptionUtils.getStackTrace(e));
Thread.sleep(waitTime);
} finally {
forEachExecution();
}
}
}