java - MessageConversionException 的通用处理程序

Question

我想处理来自队列的消息，当它们具有某种格式并且可以反序列化为某个Java类时。为此，我创建了以下方法。

@JmsListener(destination = "myQueue", containerFactory = "myFactory")
public void receiveMessage(Message message) {
    service.process(message);
}

但是，当消息无法反序列化为 Message 类的实例时，我得到 org.springframework.messaging.converter.MessageConversionException ，我想处理该异常并记录消息的内容。标准的做法是什么？是否有任何注释来定义方法？

Answer 1

您可以将自定义 ErrorHandler 添加到监听器容器工厂 - 请参阅 Annotation-driven listener endpoints .

@Configuration
@EnableJms
public class AppConfig {

        @Bean
        public DefaultJmsListenerContainerFactory jmsListenerContainerFactory() {
                DefaultJmsListenerContainerFactory factory =
                                new DefaultJmsListenerContainerFactory();
                factory.setConnectionFactory(connectionFactory());
                factory.setDestinationResolver(destinationResolver());
                factory.setConcurrency("3-10");
                return factory;
        }
}

添加factory.setErrorHandler(myErrorHandler())。