in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/Common.java [51:61]
static long upcomingIndex(MongoCollection<Document> col) {
Document doc = col.find(lte(INDEX, Long.MAX_VALUE))
.sort(descending(INDEX))
.first();
if (doc != null) {
long latestAvailable = doc.getLong(INDEX);
return latestAvailable + 1L;
} else {
return 0L;
}
}