Spring JMS映射Jackson2MessageConverter-无法处理错误

Question

我将Spring JMS与ActiveMQ一起使用，并使用MappingJackson2MessageConverter在各个组件之间传递消息。

我的核心问题是，当MappingJackson2MessageConverter遇到内部反序列化错误时，当将String反序列化为某个Object时，这些异常不会以任何我可以响应的方式引发。我的错误处理程序逻辑从未被调用，也没有抛出我可以访问的异常。这些反序列化错误似乎被完全吞噬了，当它们被记录在控制台中时，我没有机会执行自定义逻辑来响应它们。

我将我的MappingJackson2MessageConverterbean定义如下：

@Bean
public MessageConverter jacksonJmsMessageConverter() {
MappingJackson2MessageConverter converter = new MappingJackson2MessageConverter();
converter.setTargetType(MessageType.TEXT);
converter.setTypeIdPropertyName("_type");
return converter;
}

我定义JMS侦听器工厂如下：

@Bean
public JmsListenerContainerFactory<?> jmsListenerQueueFactory(ConnectionFactory connectionFactory,
DefaultJmsListenerContainerFactoryConfigurer configurer, JmsErrorHandler jmsErrorHandler) {
DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
factory.setErrorHandler(jmsErrorHandler); // <-- I expect this to be used
configurer.configure(factory, connectionFactory);
return factory;
}

在上述线路中，重要的是setErrorHandler呼叫。我定义了一个简单的ErrorHandler对象，它试图捕获@JmsListener方法可能引发的错误。这个简单的错误处理程序如下所示：

public class JmsErrorHandler implements ErrorHandler {
@Override
public void handleError(Throwable t) {
System.out.println("WE HAVE THE ERROR!");
}
}

我的听众也很简单，如下所示：

@JmsListener(id = MY_ID, destination = MY_DEST)
public void processMessage(MyPojoMessage myPojoMessage) {
// This code is obviously never reached, since the serialization error occurs. 

总的来说，这是一个非常简单和基本的设置。现在，当我发送一条无效消息时，Jackson将解析失败，我在控制台中收到以下错误：

19-10-2020 09:05:33.933 [35m[DefaultMessageListenerContainer-1][0;39m [31mWARN [0;39m o.s.j.l.DefaultMessageListenerContainer.invokeErrorHandler - Execution of JMS message listener failed, and no ErrorHandler has been set.
org.springframework.jms.listener.adapter.ListenerExecutionFailedException: Listener method 'public void com.example.processMessage(com.example.MyPojoMessage)' threw exception; nested exception is org.springframework.jms.support.converter.MessageConversionException: Failed to convert JSON message content; nested exception is com.fasterxml.jackson.databind.JsonMappingException

这个异常是意料之中的——因为我提供了一个无效的负载，Jackson无法序列化它。然而，对于我来说，似乎没有办法来配置代码，以便以我可以响应的方式实际捕获此异常。我在上面的代码中设置了错误处理程序。然而，日志抱怨no ErrorHandler has been set似乎是错误的。

我看不出有什么其他方法可以引用杰克逊内心的例外。有办法吗？

Answer 1

看起来ConditionalOnMissingBean自动配置在bean名称上

所以你应该有这样的东西。

@Bean
public JmsListenerContainerFactory<?> jmsListenerContainerFactory(ConnectionFactory connectionFactory,
DefaultJmsListenerContainerFactoryConfigurer configurer, JmsErrorHandler jmsErrorHandler) {
DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
factory.setErrorHandler(jmsErrorHandler); // <-- I expect this to be used
configurer.configure(factory, connectionFactory);
return factory;
}