public T call()

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();
            }
        }
    }