in src/main/java/org/apache/sling/distribution/journal/impl/publisher/QueueCacheSeeder.java [103:115]
private void delay(long sleepMs) {
long sleepCycles = sleepMs / 100;
for (int curCycle=0; curCycle < sleepCycles; curCycle++) {
if (closed) {
return;
}
try {
Thread.sleep(100);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}
}
}