private void publish1()

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;
            }
        }
    }