GH-368 - Consider filter handed into IncompleteEventPublications.resubmitIncompletePublications(…).

Original pull request: GH-367.

Author: benjaminknauer

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

@@ -150,7 +150,7 @@ protected Collection<ApplicationListener<?>> getApplicationListeners(Application
 	*/
 	@Override
 	public void resubmitIncompletePublications(Predicate<EventPublication> filter) {
-		doResubmitUncompletedPublicationsOlderThan(null);
+		doResubmitUncompletedPublicationsOlderThan(null, filter);
 	}
 
 	/*
@@ -159,7 +159,7 @@ public void resubmitIncompletePublications(Predicate<EventPublication> filter) {
 	 */
 	@Override
 	public void resubmitIncompletePublicationsOlderThan(Duration duration) {
-		doResubmitUncompletedPublicationsOlderThan(duration);
+		doResubmitUncompletedPublicationsOlderThan(duration, __ -> true);
 	}
 
 	/*
@@ -192,7 +192,7 @@ private void invokeTargetListener(TargetEventPublication publication) {
 				});
 	}
 
-	private void doResubmitUncompletedPublicationsOlderThan(@Nullable Duration duration) {
+	private void doResubmitUncompletedPublicationsOlderThan(@Nullable Duration duration, Predicate<EventPublication> filter) {
 
 		var message = duration != null ? "" : " older than %s".formatted(duration);
 		var registry = this.registry.get();
@@ -205,7 +205,9 @@ private void doResubmitUncompletedPublicationsOlderThan(@Nullable Duration durat
 
 		LOGGER.debug(getConfirmationMessage(publications) + " found.");
 
-		publications.forEach(this::invokeTargetListener);
+		publications.stream() //
+			.filter(filter) //
+			.forEach(this::invokeTargetListener);
 	}
 
 	private static ApplicationListener<ApplicationEvent> executeListenerWithCompletion(EventPublication publication,