private void handlePackageMessage()

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

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

    private void handlePackageMessage(MessageInfo info, PackageMessage message) {
        if (shouldEnqueue(info, message)) {
            distributionMetricsService.getPackageJournalDistributionDuration()
                    .update((currentTimeMillis() - info.getCreateTime()), TimeUnit.MILLISECONDS);
            enqueue(new FullMessage<>(info, message));
        } else {
            try {
                bookKeeper.skipPackage(info.getOffset());
            } catch (PersistenceException | LoginException e) {
                LOG.warn("Error marking distribution package {} at offset={} as skipped", message, info.getOffset(), e);
            }
        }
    }