public Message receive()

in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MessageReceiverImpl.java [56:61]

• 6 lines of code
• 1 McCabe index (conditional complexity)

    public Message receive(long index) throws InterruptedException {
        fetch(index);
        long bufferIndex = index - firstIndex;
        assert bufferIndex < buffer.size() : bufferIndex + ", " + buffer.size();
        return buffer.get((int) bufferIndex);
    }