private synchronized Entry waitNext()

in org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/Topic.java [69:77]

• 9 lines of code
• 2 McCabe index (conditional complexity)

    private synchronized Entry<Long, Message> waitNext(long currentOffset) throws InterruptedException {
        Entry<Long, Message> entry = journal.getNext(currentOffset);
        if (entry != null) {
            return entry;
        }
        log.debug("Waiting for next message");
        wait();
        return journal.getNext(currentOffset);
    }