spring JMS 错误处理程序未调用答案

【问题标题】：spring JMS error handler is not Invokingspring JMS 错误处理程序未调用
【发布时间】：2016-08-04 16:36:33
【问题描述】：

我的 Spring JMS 消息监听器容器设置如下。

    <beans:bean id="messageListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">     
            <beans:property name="connectionFactory" ref="amqConnectionFactory" />
            <beans:property name="destination" ref="request.Queue" />
            <beans:property name="messageListener" ref="messageListener" /> 
            <beans:property name="sessionTransacted" value="true" />        
            <beans:property name="errorHandler" ref="inboundErrorHandler"/>              
        </beans:bean>

<beans:bean id="inboundErrorHandler" class="com.test.exception.MDPErrorHandler" />

监听代码如下..

@Component
public class MyMessageListener implements MessageListener {

    private static final Log LOG = LogFactory.getLogger(MyMessageListener.class);

    @Autowired
    private MessageHandler handler;

    /**
     * @see MessageListener#onMessage(Message)
     */
    @Override   
    public void onMessage(Message inMessage) {  

         try
            {   
                if (inMessage instanceof TextMessage) {
                    TextMessage msg = (TextMessage) inMessage;                      
                    handler.processRequest(msg.getText());                                                 
                } else {
                    LOG.error("Message of wrong type: " + inMessage.getClass().getName());
                }

           } catch (Exception cause) {
              LOG.error("Error while receiving message in MlaMessageListener.onMesage() ",cause);
           }
    }   

}

我的错误处理程序如下..

public class MDPErrorHandler implements ErrorHandler {
    /** 
     * @see org.springframework.util.ErrorHandler#handleError(java.lang.Throwable)
     */
    @Override
    public void handleError(Throwable t) {
        LOG.warn("Inside MDPErrorHandler.handleError()*** ");
        t.printStackTrace();
    }
}

如果 messageListener.onMessage() 中发生任何异常/错误，为什么我的错误处理程序不会自动调用？

我需要手动调用它吗？

【问题讨论】：

标签： spring jakarta-ee error-handling spring-integration spring-jms

【解决方案1】：

你不需要像那样配置容器。

只需向入站适配器添加一个错误通道；当主流程（incomingUpdateChannel->）发生异常时，错误消息将被发送到错误通道。该消息的有效负载将是一个 MessagingException，您可以提取失败的消息以尝试发送到您的失败队列。只需添加一个转换器 (expresssion="payload.failedMessage")，然后是一个 jms 出站适配器。如果发送成功，原始事务将提交。如果错误通道流抛出异常，则原消息将被回滚。

【讨论】：

感谢您的回复。但我猜你建议的解决方案适用于弹簧集成。我没有在我的应用程序中使用它。我只使用普通的弹簧 jms。没有弹簧集成。