private DistributionQueue getErrorQueue()

in src/main/java/org/apache/sling/distribution/journal/queue/impl/PubQueueProviderImpl.java [184:197]

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

    private DistributionQueue getErrorQueue(String pubAgentName, String queueName) {
        AgentId subAgentId = new AgentId(StringUtils.substringBeforeLast(queueName, "-error"));
        String errorQueueKey = getErrorQueueKey(pubAgentName, subAgentId.getSlingId(), subAgentId.getAgentName());
        OffsetQueue<Long> errorQueue = errorQueues.getOrDefault(errorQueueKey, new OffsetQueueImpl<>());
        final Long minReferencedOffset = errorQueue.getHeadItem();
        final OffsetQueue<DistributionQueueItem> agentQueue;
        if (minReferencedOffset == null) {
            agentQueue = new OffsetQueueImpl<>();
        } else {
            agentQueue = getOffsetQueue(pubAgentName, minReferencedOffset);
        }

        return new PubErrQueue(queueName, agentQueue, errorQueue);
    }