private boolean shouldEnqueue()

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

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

    private boolean shouldEnqueue(MessageInfo info, PackageMessage message) {
        if (!queueNames.contains(message.getPubAgentName())) {
            LOG.info("Skipping distribution package {} at offset={} (not subscribed)", message, info.getOffset());
            return false;
        }
        if (!pkgType.equals(message.getPkgType())) {
            LOG.warn("Skipping distribution package {} at offset={} (bad pkgType)", message, info.getOffset());
            return false;
        }
        return true;
    }