in org.apache.aries.events.memory/src/main/java/org/apache/aries/events/memory/Topic.java [57:67]
private long getStartOffset(MemoryPosition position, Seek seek) {
if (position != null) {
return position.getOffset();
} else {
if (seek == Seek.earliest) {
return this.journal.getFirstOffset();
} else {
return this.journal.getLastOffset() + 1;
}
}
}