JMS消息偵聽器的執行失敗，並且沒有設置ErrorHandler

Question

當我使用Spring來偵聽JMS消息時，我收到了上述錯誤。

我想知道如何將一個Errorhandler添加到JMS監聽器中？

Answer 1

有上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> 

凡someHandler是一個bean實現ErrorHandler：

的默認行爲：

@Service 
public class SomeHandler implements ErrorHandler { 

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

，根據documentation但是注意這個消息監聽器的代碼將會是在錯誤級別處記錄任何此類異常。 [...]但是，如果需要錯誤處理，則可以將任何ErrorHandler策略的實現提供給setErrorHandler（ErrorHandler）方法。

查看您的日誌，可能是已經記錄的異常？

Answer 2

沒有xml配置。我在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

萬一時使用的默認出廠：

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

Answer 4

我喜歡簡短而親切！

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