in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MessageSenderImpl.java [104:115]
private void publish1(Message message, int retry) {
try {
long index = upcomingIndex(collection);
collection.insertOne(createDoc(index, message));
} catch (MongoWriteException e) {
if (retry > 0) {
publish1(message, retry - 1);
} else {
throw e;
}
}
}