public synchronized void busy()

in src/main/java/org/apache/sling/distribution/journal/impl/subscriber/SubscriberReady.java [83:95]

• 13 lines of code
• 4 McCabe index (conditional complexity)

    public synchronized void busy(int retries, long messageCreateTime) {
        if (isReady()) {
            return;
        }
        cancelSchedule();
        long latency = timeProvider.get() - messageCreateTime;
        if (latency < acceptableAgeDiffMs) {
            ready(String.format("Package message latency %d s < %d s acceptable limit", MILLISECONDS.toSeconds(latency), MILLISECONDS.toSeconds(acceptableAgeDiffMs)));
        }
        if (retries > MAX_RETRIES) {
            ready(String.format("Retries %d > %d", retries, MAX_RETRIES));
        }
    }