在下面的配置中,我有一个带有message-converter
的message-driven-channel-adapter
,因此使用转换后的有效负载调用service-activator
。
<int-jms:message-driven-channel-adapter id="myConsumerChannelAdapter" connection-factory="connectionFactory"
destination="input_queue" channel="input_channel" error-channel="errorChannel"
message-converter="messageConverter" header-mapper="jmsHeaderMapper" acknowledge="client" max-concurrent-consumers="10"/>
<int:service-activator input-channel="input_channel" output-channel="output_enricher_channel" ref="MyConsumer"/>
如果MyConsumer
抛出异常,则会将其发送到errorChannel
。到目前为止,它按预期工作。但是,当消息转换器抛出类似MessageConversionException
的异常时,它不会被发送到errorChannel
。如果我记录由消息转换器引起的异常,我会得到:
AbstractMessageListenerContainer.invokeErrorHandler(875) | Execution of JMS message listener failed, and no ErrorHandler has been set.
但是,我如何将ErrorHandler
分配给我的通道适配器或将这些异常发送给我的errorChannel
?
这将在即将发布的4.2版本中提供。
https://jira.spring.io/browse/INT-3670
在此处提交。
我向JIRA提出的stackoverflow问题有一个(某种)解决办法,但它有点笨拙。
您可以尝试4.2.0.BUILD-SNAPSHOT进行测试;在接下来的几周里将会有一个里程碑,但最终的发布计划要到夏末才能完成。