private FullMessage blockingPeekQueueItem()

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

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

    private FullMessage<PackageMessage> blockingPeekQueueItem() throws InterruptedException {
        while (running) {
            FullMessage<PackageMessage> message = messageBuffer.peek();
            if (message != null) {
                return message;
            } else {
                delay.await(QUEUE_FETCH_DELAY);
            }
        }
        throw new InterruptedException("Shutting down");
    }