消费者抛出异常后重新传递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