private void blockingSendStoredStatus()

in src/main/java/org/apache/sling/distribution/journal/impl/subscriber/DistributionSubscriber.java [358:369]

• 12 lines of code
• 3 McCabe index (conditional complexity)

    private void blockingSendStoredStatus() throws InterruptedException, IOException {
        try (Timer.Context context = distributionMetricsService.getSendStoredStatusDuration().time()) {
            int retry = 0;
            while (running) {
                if (bookKeeper.sendStoredStatus(retry)) {
                    return;
                }
                retry++;
            }
        }
        throw new InterruptedException("Shutting down");
    }