in src/main/java/org/apache/sling/distribution/journal/impl/subscriber/DistributionSubscriber.java [308:320]
private void enqueue(FullMessage<PackageMessage> message) {
try {
while (running) {
if (messageBuffer.offer(message, 1000, TimeUnit.MILLISECONDS)) {
distributionMetricsService.getItemsBufferSize().increment();
return;
}
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
throw new RuntimeException();
}