int getSleepTime()

in src/main/java/org/apache/sling/distribution/journal/impl/publisher/DistributionPublisher.java [220:228]


    int getSleepTime(int queueSize) {
        if (!limitEnabled || queueSize <= queueSizeLimit) {
            return 0;
        } else if (queueSize >= queueSizeLimit*2) {
            return maxQueueSizeDelay;
        } else {
            return (queueSize-queueSizeLimit) * maxQueueSizeDelay / queueSizeLimit;
        }
    }