public DistributionQueueStatus getStatus()

in src/main/java/org/apache/sling/distribution/journal/queue/impl/PubQueue.java [198:215]

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

    public DistributionQueueStatus getStatus() {
        final DistributionQueueState queueState;
        final int itemsCount;
        DistributionQueueEntry headEntry = getHead();
        if (headEntry != null) {
            itemsCount = offsetQueue.getSize();
            DistributionQueueItemStatus status = headEntry.getStatus();
            if (status.getItemState() == DistributionQueueItemState.ERROR && status.getAttempts() >= BLOCKED_AFTER_NUM_ATTEMPTS) {
            	queueState = BLOCKED;
            } else {
            	queueState = RUNNING;
            }
        } else {
            itemsCount = 0;
            queueState = IDLE;
        }
        return new DistributionQueueStatus(itemsCount, queueState);
    }