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;
}
}