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 d037e128..1b4c2d5a 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 @@ -141,7 +141,7 @@ public class DefaultEventPublicationRegistry @Override public void deletePublications(Predicate filter) { - var identifiers = findIncompletePublications().stream() + var identifiers = findAll().stream() .filter(filter) .map(TargetEventPublication::getIdentifier) .toList();