Skip to content

Commit ac8f699

Browse files
lukasdoooodrotbohm
authored andcommitted
GH-502 - Only delete completed events.
1 parent 7e6c111 commit ac8f699

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

spring-modulith-events/spring-modulith-events-core/src/main/java/org/springframework/modulith/events/core/DefaultEventPublicationRegistry.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -141,7 +141,7 @@ public Collection<? extends TargetEventPublication> findAll() {
141141
@Override
142142
public void deletePublications(Predicate<EventPublication> filter) {
143143

144-
var identifiers = findIncompletePublications().stream()
144+
var identifiers = findAll().stream()
145145
.filter(filter)
146146
.map(TargetEventPublication::getIdentifier)
147147
.toList();

0 commit comments

Comments
 (0)