diff --git a/spring-modulith-events/spring-modulith-events-mongodb/src/main/java/org/springframework/modulith/events/mongodb/MongoDbEventPublicationRepository.java b/spring-modulith-events/spring-modulith-events-mongodb/src/main/java/org/springframework/modulith/events/mongodb/MongoDbEventPublicationRepository.java index a6ffd5b4..a3339dab 100644 --- a/spring-modulith-events/spring-modulith-events-mongodb/src/main/java/org/springframework/modulith/events/mongodb/MongoDbEventPublicationRepository.java +++ b/spring-modulith-events/spring-modulith-events-mongodb/src/main/java/org/springframework/modulith/events/mongodb/MongoDbEventPublicationRepository.java @@ -89,7 +89,7 @@ class MongoDbEventPublicationRepository implements EventPublicationRepository { var update = Update.update(COMPLETION_DATE, completionDate); - mongoTemplate.updateFirst(byEventAndListenerId(event, identifier), update, MongoDbEventPublication.class); + mongoTemplate.findAndModify(byEventAndListenerId(event, identifier), update, MongoDbEventPublication.class); } /*