private void fetch()

in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MessageReceiverImpl.java [108:114]

• 7 lines of code
• 3 McCabe index (conditional complexity)

    private void fetch(long index) throws InterruptedException {
        while (firstIndex > index || firstIndex + buffer.size() <= index) {
            long delay = min(maxWaitTime, (currentTimeMillis() - lastReceived) / 2);
            adaptivePause(delay);
            refreshBuffer(index);
        }
    }