消費者拋出異常後重新傳遞Activemq消息

Question

我有一個消費者使用消息並將消息寫入數據庫的應用程序。我正在使用Spring的DefaultMessageListenerContainer。有沒有辦法消費一條消息，並拋出數據庫異常將消息放回隊列？

Answer 1

setSessionTransacted(true)

如果你使用了命名空間配置容器，使用

<jms:listener-container acknowledge="transacted" ...> 
    <jms:listener ... /> 
</jms:listener-container> 

您也可能想通過將JDBC事務管理到容器配置到數據庫和JMS交易同步。

請參閱Dave Syer's Javaworld Article about Distributed transactions in Spring, with and without XA