From 80e53accf7758249af32d3a5772322da91bf5825 Mon Sep 17 00:00:00 2001 From: Oliver Drotbohm Date: Tue, 14 Nov 2023 11:01:49 +0100 Subject: [PATCH] GH-368 - Integration tests. --- .../PersistentDomainEventIntegrationTest.java | 16 +++++++++++++++- 1 file changed, 15 insertions(+), 1 deletion(-) diff --git a/spring-modulith-events/spring-modulith-events-tests/src/test/java/example/events/PersistentDomainEventIntegrationTest.java b/spring-modulith-events/spring-modulith-events-tests/src/test/java/example/events/PersistentDomainEventIntegrationTest.java index 22ec008b..648eed43 100644 --- a/spring-modulith-events/spring-modulith-events-tests/src/test/java/example/events/PersistentDomainEventIntegrationTest.java +++ b/spring-modulith-events/spring-modulith-events-tests/src/test/java/example/events/PersistentDomainEventIntegrationTest.java @@ -87,7 +87,9 @@ class PersistentDomainEventIntegrationTest { } // Resubmit failed publications - context.getBean(IncompleteEventPublications.class).resubmitIncompletePublications(__ -> true); + var incompletePublications = context.getBean(IncompleteEventPublications.class); + + incompletePublications.resubmitIncompletePublications(__ -> true); Thread.sleep(200); @@ -100,6 +102,18 @@ class PersistentDomainEventIntegrationTest { // Still 2 uncompleted publications assertThat(registry.findIncompletePublications()).hasSize(2); + incompletePublications.resubmitIncompletePublications(it -> { + return TargetEventPublication.class.cast(it) + .getTargetIdentifier() + .getValue().contains(SecondTxEventListener.class.getName()); + }); + + assertThat(context.getBean(NonTxEventListener.class).getInvoked()).isEqualTo(1); + assertThat(context.getBean(FirstTxEventListener.class).getInvoked()).isEqualTo(1); + assertThat(context.getBean(SecondTxEventListener.class).getInvoked()).isEqualTo(3); + assertThat(context.getBean(ThirdTxEventListener.class).getInvoked()).isEqualTo(1); + assertThat(context.getBean(FourthTxEventListener.class).getInvoked()).isEqualTo(2); + context.close(); }