private void blockingSendStoredStatus()

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

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

    private void blockingSendStoredStatus() throws InterruptedException {
        try (Timer.Context context = subscriberMetrics.getSendStoredStatusDuration().time()) {
            int retry = 0;
            while (running) {
                if (bookKeeper.sendStoredStatus(retry)) {
                    return;
                }
                retry++;
            }
        } catch (IOException e) {
        	// Ignore .. This is just from timer close
		}
        
        throw new InterruptedException("Shutting down");
    }