public DistributionQueue getQueue()

in src/main/java/org/apache/sling/distribution/journal/impl/publisher/DistributionPublisher.java [178:189]


    public DistributionQueue getQueue(String queueName) {
        try {
            DistributionQueue queue = pubQueueProvider.getQueue(pubAgentName, queueName);
            if (queue == null) {
                publishMetrics.getQueueAccessErrorCount().increment();
            }
            return queue;
        } catch (Exception e) {
            publishMetrics.getQueueAccessErrorCount().increment();
            throw e;
        }
    }