单独的 JmsListeners 的单独 ErrorHandlers

Question

如何为整个JmsListenerContainerFactory设置一个ErrorHandler。

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

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

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

我尝试使用

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

但是

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

请多多指教

Answer 1

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

/**
 * The bean name of the {@link org.springframework.jms.config.JmsListenerContainerFactory}
 * to use to create the message listener container responsible for serving this endpoint.
 * <p>If not specified, the default container factory is used, if any.
 */
String containerFactory() default "";

单独的 JmsListeners 的单独 ErrorHandlers

Separate ErrorHandlers for separate JmsListeners

spring-jms

spring-messaging