public SubscriberReady()

in src/main/java/org/apache/sling/distribution/journal/impl/subscriber/SubscriberReady.java [61:73]

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

    public SubscriberReady(String subAgentName, long idleMillis, long forceIdleMillies, long acceptableAgeDiffMs, AtomicBoolean readyHolder, Supplier<Long> timeProvider) {
        this.subAgentName = subAgentName;
        this.idleMillis = idleMillis;
        this.forceIdleMillies = forceIdleMillies;
        this.acceptableAgeDiffMs = acceptableAgeDiffMs;
        this.isReady = readyHolder;
        this.timeProvider = timeProvider;
        this.startTime = timeProvider.get();
        executor = Executors.newScheduledThreadPool(2);
        forceShedule = executor.schedule(this::forceIdle, forceIdleMillies, TimeUnit.MILLISECONDS);
        idle();
        log.info("Started");
    }