private void enqueue()

in src/main/java/org/apache/sling/distribution/journal/impl/subscriber/DistributionSubscriber.java [308:320]

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

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