private void handlePackage()

in src/main/java/org/apache/sling/distribution/journal/impl/publisher/RangePoller.java [95:105]

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

    private void handlePackage(MessageInfo info, PackageMessage message) {
        long offset = info.getOffset();
        LOG.debug("Consuming distribution package {} at offset={}", message, offset);
        if (offset < maxOffset) {
            if (isNotTestMessage(message)) {
                messages.add(new FullMessage<>(info, message));
            }
        } else {
            fetched.countDown();
        }
    }