private void handleMessage()

in org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/Topic.java [105:115]

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

        private void handleMessage(Entry<Long, Message> entry) {
            long offset = entry.getKey();
            try {
                MemoryPosition position = new MemoryPosition(this.currentOffset);
                Received received = new Received(position, entry.getValue());
                callback.accept(received);
            } catch (Exception e) {
                log.warn(e.getMessage(), e);
            }
            this.currentOffset = offset + 1;
        }