private void adaptivePause()

in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MessageReceiverImpl.java [149:162]

• 14 lines of code
• 4 McCabe index (conditional complexity)

    private void adaptivePause(long ms) throws InterruptedException {
        if (interrupted) {
            throw new InterruptedException();
        }
        long currentTime = currentTimeMillis();
        long stopTime = currentTime + ms;
        while (currentTime < stopTime) {
            if (interrupted) {
                throw new InterruptedException();
            }
            sleep(min(FINE_GRAINED_DELAY, ms));
            currentTime = currentTimeMillis();
        }
    }