How can I get the Modulith event publication id if an exception is thrown by the method annotated with @ApplicationModuleListener?

[dustinsand]

My use case is to write the exception thrown by a Listener annotated with @ApplicationModuleListener to a custom table, event_publication_event_publication_retry_history that has a foreign key to Modulith's event_publication.id column. This table is part of of our custom retry library for Modulith so developers can find the cause of the event failure when troubleshooting is required after the retry limit for the event has been exceeded.

CREATE TABLE IF NOT EXISTS event_publication_retry_history
(
id SERIAL,
event_publication_id UUID NOT NULL,
failure_reason TEXT NOT NULL,
failure_datetime TIMESTAMP WITH TIME ZONE NOT NULL,
PRIMARY KEY (id),
CONSTRAINT fk_event_publication_id FOREIGN KEY (event_publication_id) REFERENCES event_publication (id) ON DELETE CASCADE
);

Is there a way to add an interceptor as part of Moduliths handling of the failed event to hook into to write the exception to this table too?

[dustinsand]

Found a way with Modulith 1.1.0 by implementing a org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler.AsyncUncaughtExceptionHandler used by a org.springframework.scheduling.annotation.AsyncConfigurer. The handleUncaughtException finds the TargetEventPublication by calling EventPublicationRepository.findIncompletePublicationsByEventAndTargetIdentifier passing the original event and the listener_id for the listener that handled the event.

@Override
  public void handleUncaughtException(
      Throwable throwable, Method method, Object @NotNull ... params) {
    // Only handle exception if from a method annotated with Modulith's @ApplicationModuleListener.
    // Listener will only have one param, the event.
    if (params.length == 1
        && (method.isAnnotationPresent(
                org.springframework.modulith.events.ApplicationModuleListener.class)
            || method.isAnnotationPresent(
                org.springframework.modulith.ApplicationModuleListener.class))) {
      try {
        Object event = Arrays.stream(params).toArray()[0];
        Optional<TargetEventPublication> incompletePublication =
            eventPublicationRepo.findIncompletePublicationsByEventAndTargetIdentifier(
                event,
                PublicationTargetIdentifier.of(formatMethodPerModulithListenerIdFormat(method)));

        if (incompletePublication.isPresent()) {
                    eventPublicationRetryHistoryRepo.save(
              new EventPublicationRetryHistory(
                  incompletePublication.get().getIdentifier(),
                  stackTraceToString(throwable),
                  Instant.now()));
        } else {
          log.error(
              "Modulith event publication not found for exception thrown by event: {}", event);
        }
      } catch (Exception e) {
        log.error("Failed to handle exception from Spring Modulith listener: {}", e.getMessage());
      }
}

@NotNull
  private static String formatMethodPerModulithListenerIdFormat(Method method) {
    StringBuilder sb = new StringBuilder();
    sb.append(method.getDeclaringClass().getTypeName()).append('.');
    sb.append(method.getName());
    sb.append(
        Arrays.stream(method.getParameterTypes())
            .map(Type::getTypeName)
            .collect(Collectors.joining(",", "(", ")")));

    return sb.toString();
  }

This works, but is there a better way to solve this use case?