单独的 JmsListeners 的单独 ErrorHandlers

问题描述

Here is answered 如何为整个 ErrorHandler 设置 JmsListenerContainerFactory。

但我需要每个 JmsListener (DefaultMessageListenerContainer) 都有自己的 ErrorHandler。

仅在我的侦听器中使用 try-catch 是不合适的，因为它不会捕获 JMS 事务的失败（事务在 Spring 中提交，在我的侦听器之外）。

我想通过监控系统收集此类故障。

我尝试使用

JmsListenerEndpointRegistry
  .getListenerContainers()
  .forEach{ it.errorHandler = myErrorHandler }

但是

1. 这有点棘手。
2. 容器的注册晚于 JmsListener 注释的 bean 由其 BeanPostProcessor 处理。所以我很难选择一个时刻来设置错误处理程序。

请指教。

解决方法

我看到的唯一方法是为所有不同的 customID 及其特定的 JmsListenerContainerFactory 配置单独的 @JmsListener bean。这些 ErrorHandler 中的每一个都应该从这个选项中引用他们自己的工厂：

@JmsListener