public RangePoller()

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

• 17 lines of code
• 1 McCabe index (conditional complexity)

    public RangePoller(MessagingProvider messagingProvider,
                          String packageTopic,
                          long minOffset,
                          long maxOffsetExclusive,
                          int seedDelaySeconds) {
        this.maxOffset = maxOffsetExclusive;
        this.minOffset = minOffset;
        this.seedDelaySeconds = seedDelaySeconds;
        this.messages = new ArrayList<>();
        String assign = messagingProvider.assignTo(minOffset);
        LOG.info("Fetching offsets [{},{}[", minOffset, maxOffsetExclusive);
        sender = messagingProvider.createSender(packageTopic);
        headPoller = messagingProvider.createPoller(
                packageTopic, Reset.earliest, assign,
                create(PackageMessage.class, this::handlePackage)
                );
    }