java - Spring JMS : Set ErrorHandler for @JmsListener annotated method

Question

我正在使用一个 @JmsListener 注释方法来监听 JMS 消息，如下所示。

@JmsListener(destination="exampleQueue")  
public void fetch(@Payload String message){  
    process(message);  
}

当这个方法执行导致异常时，我得到一个警告日志

Execution of JMS message listener failed, and no ErrorHandler has been set.

如何设置 ErrorHandler 来处理这种情况。我正在使用 spring boot 1.3.3.RELEASE

Answer 1

当使用像@EnableJms, @JmsListener 等注解来和Spring JMS一起工作时，ErrorHandler可以这样设置

@Bean
public DefaultJmsListenerContainerFactory jmsListenerContainerFactory(ConnectionFactory connectionFactory, ExampleErrorHandler errorHandler) {
    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    factory.setErrorHandler(errorHandler);
    return factory;
}

@Service
public class ExampleErrorHandler implements ErrorHandler{   
    @Override
    public void handleError(Throwable t) {
        //handle exception here
    }
}

此处提供更多详细信息:Annotation-driven listener endpoints