diff --git a/spring-modulith-events/spring-modulith-events-core/src/main/java/org/springframework/modulith/events/core/DefaultEventPublicationRegistry.java b/spring-modulith-events/spring-modulith-events-core/src/main/java/org/springframework/modulith/events/core/DefaultEventPublicationRegistry.java index 68ae31bf..4fc12e51 100644 --- a/spring-modulith-events/spring-modulith-events-core/src/main/java/org/springframework/modulith/events/core/DefaultEventPublicationRegistry.java +++ b/spring-modulith-events/spring-modulith-events-core/src/main/java/org/springframework/modulith/events/core/DefaultEventPublicationRegistry.java @@ -158,9 +158,7 @@ public class DefaultEventPublicationRegistry var now = clock.instant(); - deletePublications(event -> event.getCompletionDate() - .filter(date -> date.isBefore(now.minus(duration))) - .isPresent()); + events.deleteCompletedPublicationsBefore(now.minus(duration)); } /*