public Iterable getEntries()

in src/main/java/org/apache/sling/distribution/journal/queue/impl/PubErrQueue.java [84:95]

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

    public Iterable<DistributionQueueEntry> getEntries(int skip, int limit) {
        List<DistributionQueueEntry> entries = new ArrayList<>();
        for (long refOffset : errorQueue.getHeadItems(skip, limit)) {
            DistributionQueueItem queueItem = agentQueue.getItem(refOffset);
            if (queueItem != null) {
                entries.add(entryFactory.create(queueItem));
            } else {
                LOG.warn("queueItem at offset {} not found", refOffset);
            }
        }
        return entries;
    }