GH-372 - Propagate original exception from CompletionRegisteringAdvisor.

We now propagate potentially occurring exceptions in CompletionRegisteringAdvisor to make sure the standard exception handling facilities kick in, both for synchronous and asynchronous listener invocations.

Author: odrotbohm

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

@@ -23,7 +23,6 @@
 import org.aopalliance.intercept.MethodInvocation;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-import org.springframework.aop.Advisor;
 import org.springframework.aop.MethodMatcher;
 import org.springframework.aop.Pointcut;
 import org.springframework.aop.support.AbstractPointcutAdvisor;
@@ -41,8 +40,8 @@
 import org.springframework.util.ConcurrentLruCache;
 
 /**
- * An {@link Advisor} to decorate {@link TransactionalEventListener} annotated methods to mark the previously registered
- * event publications as completed on successful method execution.
+ * An {@link org.springframework.aop.Advisor} to decorate {@link TransactionalEventListener} annotated methods to mark
+ * the previously registered event publications as completed on successful method execution.
  *
  * @author Oliver Drotbohm
  */
@@ -177,7 +176,7 @@ public Object invoke(MethodInvocation invocation) throws Throwable {
 							method, o_O.getMessage());
 				}
 
-				return result;
+				throw o_O;
 			}
 
 			// Mark publication complete if the method is a transactional event listener.

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

@@ -29,7 +29,6 @@
 import org.springframework.context.ApplicationListener;
 import org.springframework.context.PayloadApplicationEvent;
 import org.springframework.context.event.AbstractApplicationEventMulticaster;
-import org.springframework.context.event.ApplicationEventMulticaster;
 import org.springframework.context.event.ApplicationListenerMethodAdapter;
 import org.springframework.core.ResolvableType;
 import org.springframework.core.annotation.AnnotationAwareOrderComparator;
@@ -41,7 +40,6 @@
 import org.springframework.modulith.events.core.PublicationTargetIdentifier;
 import org.springframework.transaction.event.TransactionPhase;
 import org.springframework.transaction.event.TransactionalApplicationListener;
-import org.springframework.transaction.event.TransactionalEventListener;
 import org.springframework.util.Assert;
 import org.springframework.util.ReflectionUtils;
 
@@ -174,7 +172,13 @@ private void invokeTargetListener(EventPublication publication) {
 	private ApplicationListener<ApplicationEvent> executeListenerWithCompletion(EventPublication publication,
 			TransactionalApplicationListener<ApplicationEvent> listener) {
 
-		listener.processEvent(publication.getApplicationEvent());
+		try {
+			listener.processEvent(publication.getApplicationEvent());
+		} catch (Exception o_O) {
+			if (LOGGER.isErrorEnabled()) {
+				LOGGER.error("Error republishing event publication " + publication, o_O);
+			}
+		}
 
 		return listener;
 	}