private void doEvict()

in org.apache.aries.events.mongo/src/main/java/org/apache/aries/events/mongo/MessageSenderImpl.java [92:102]

• 11 lines of code
• 1 McCabe index (conditional complexity)

    private void doEvict(long threshold) {
        collection.find()
                  .projection(new Document(TIME_STAMP, 1))
                  .sort(new Document(TIME_STAMP, -1))
                  .limit(1)
                  .forEach((Consumer<Document>) doc -> {
               long newestTimeStamp = timeStamp(doc);
               long adjustedThreshold = Math.min(threshold, newestTimeStamp);
               collection.deleteMany(lt(TIME_STAMP, adjustedThreshold));
           });
    }