如何使用spring的DefaultMessageListenerContainer进行手动提交？

Question

我们有一个应用程序在消息队列上侦听，我知道 dmlc 提供了一个 sessionTransacted 属性，我假设它允许我们手动提交消息接收事件，但是我不确定如何在侦听器中利用它.

似乎只要抛出一个 RuntimeException 消息就会被放回队列中，如果没有设置 ErrorHandler 则进入循环，但我们想专门提交接收。

例如

public class JMSMessageListener implements MessageListener {

    @Override
    public void onMessage(Message message) {
       // do something with the message and then manually commit
    }
}

Answer 1

A 有使用 ActiveMQ 的经验。当sessionTransacted开启时，如果你的应用程序在onMessage中意外关闭，重启后会再次处理该消息。如果会话没有被交易，它将会丢失。

您不能使用sessionTransacted 手动控制事务（除了抛出异常以回滚消息）。你可能想看看SessionAwareMessageListener，虽然我从未尝试过。