in org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/Journal.java [37:44]
public long append(T message) {
if (count.incrementAndGet() > keepAtLeast * 2) {
evict();
}
Long offset = nextOffset.getAndIncrement();
messages.put(offset, message);
return offset;
}