From ac8f69935dad48b3aa4b9fa4fc147fc149f9ec6b Mon Sep 17 00:00:00 2001
From: lukasdooo <lukas.dohmen@study.hs-duesseldorf.de>
Date: Wed, 7 Feb 2024 15:12:26 +0100
Subject: [PATCH] GH-502 - Only delete completed events.

---
 .../modulith/events/core/DefaultEventPublicationRegistry.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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<EventPublication> filter) {
 
-		var identifiers = findIncompletePublications().stream()
+		var identifiers = findAll().stream()
 				.filter(filter)
 				.map(TargetEventPublication::getIdentifier)
 				.toList();