private void sendSeedingMessages()

in src/main/java/org/apache/sling/distribution/journal/impl/publisher/QueueCacheSeeder.java [71:86]

• 16 lines of code
• 2 McCabe index (conditional complexity)

    private void sendSeedingMessages() {
        LOG.info("Start message seeder");
        int count = 1;
        long cacheSeedingDelay = CACHE_SEEDING_DELAY_MS;
        try {
            while (!closed) {
                LOG.info("Send seeding message {} then wait {} ms", count, cacheSeedingDelay);
                sendSeedingMessage();
                delay(cacheSeedingDelay);
                cacheSeedingDelay = Math.min(cacheSeedingDelay * 2, MAX_CACHE_SEEDING_DELAY_MS);
                count++;
            }
        } finally {
            LOG.info("Stop message seeder");
        }
    }