L'esecuzione del listener di messaggi JMS non è riuscita e nessun ErrorHandler è stato impostato

Question

Quando utilizzo Spring per ascoltare i messaggi JMS, ricevo l'errore sopra riportato.

Mi chiedo come aggiungere un Errorhandler nel listener JMS?

Answer 1

C'è una proprietà in AbstractMessageListenerContainer:

<bean id="listener" class="org.springframework.jms.listener.DefaultMessageListenerContainer"> 
    <property name="errorHandler" ref="someHandler"/> 
    <property name="destinationName" value="someQueue"/> 
    <property name="connectionFactory" ref="connectionFactory"/> 
</bean> 

Dove someHandler è un fagiolo attuazione ErrorHandler:

@Service 
public class SomeHandler implements ErrorHandler { 

    @Override 
    public void handleError(Throwable t) { 
     log.error("Error in listener", t); 
    } 
} 

Tuttavia notare che secondo la documentation:

Il comportamento predefinito di questo listener di messaggi [...] sarà registra tali eccezioni al livello di errore. [...] Tuttavia, se è necessaria la gestione degli errori, qualsiasi implementazione della strategia ErrorHandler può essere fornita al metodo setErrorHandler (ErrorHandler).

Controllare i log, forse l'eccezione è già registrata?

Answer 2

Senza la configurazione xml. Ho fatto quanto segue in ApplicationContext.

@Bean 
JmsListenerContainerFactory<?> jmsContainerFactory(ConnectionFactory connectionFactory, 
     SomeHandler errorHandler) { 
    SimpleJmsListenerContainerFactory factory = new SimpleJmsListenerContainerFactory(); 
    factory.setConnectionFactory(connectionFactory); 
    factory.setErrorHandler(errorHandler); 
    return factory; 
} 


// From Tomasz answer 
@Service 
public class SomeHandler implements ErrorHandler { 

    @Override 
    public void handleError(Throwable t) { 
     log.error("Error in listener", t); 
    } 
} 

Answer 3

Nel caso in cui utilizzata di fabbrica:

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

Answer 4

mi piace breve e dolce!

@Bean 
JmsListenerContainerFactory<?> jmsContainerFactory(ConnectionFactory connectionFactory) { 
    SimpleJmsListenerContainerFactory factory = new SimpleJmsListenerContainerFactory(); 
    factory.setConnectionFactory(connectionFactory); 
    factory.setErrorHandler(t -> { 
     log.error("Error in listener!", t); 
     }); 
    return factory; 
}