Java – Spring JMS : Set ErrorHandler for @JmsListener annotated method

java, jms, spring, spring-boot, spring-jms

I am using a @JmsListener annotated method listen to JMS messages as shown below.

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

When this method execution result in an exception, I got a warn log

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

How do I set an ErrorHandler to handle the case. I am using spring boot 1.3.3.RELEASE

Best Solution

While using annotations like @EnableJms, @JmsListener etc to work with Spring JMS, the ErrorHandler can be set like this

@Beanpublic DefaultJmsListenerContainerFactory jmsListenerContainerFactory(ConnectionFactory connectionFactory, ExampleErrorHandler errorHandler) {    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();    factory.setConnectionFactory(connectionFactory);    factory.setErrorHandler(errorHandler);    return factory;}@Servicepublic class ExampleErrorHandler implements ErrorHandler{       @Override    public void handleError(Throwable t) {        //handle exception here    }}

More details are available here : Annotation-driven listener endpoints