private void poll()

in org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/Topic.java [92:103]

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

        private void poll() {
            try {
                while (true) {
                    Entry<Long, Message> entry = waitNext(currentOffset);
                    if (entry != null) {
                        handleMessage(entry);
                    }
                }
            } catch (InterruptedException e) {
                log.debug("Poller thread for consumer on topic " + topicName + " stopped.");
            }
        }