private void processQueue()

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

• 18 lines of code
• 5 McCabe index (conditional complexity)

    private void processQueue() {
        LOG.info("Started Queue processor");
        while (running) {
            try {
                fetchAndProcessQueueItem();
            } catch (PreConditionTimeoutException e) {
                // Precondition timed out. We only log this on info level as it is no error
                LOG.info(e.getMessage());
                delay.await(RETRY_DELAY);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
                LOG.debug(e.getMessage());
            } catch (Exception e) {
                // Catch all to prevent processing from stopping
                LOG.error("Error processing queue item", e);
                delay.await(catchAllDelay.getAsLong());
            }
        }
        LOG.info("Stopped Queue processor");
    }