java - Spring JMS 监听器即使在异常时也承认

Question

我正在使用 JMS 向我的 SQS 队列发送/接收消息，但是即使在使用 client_acknowledge 时出现异常，我也无法重新传送消息。如何做到这一点？我尝试了一个简单的测试，

@JmsListener(destination = "test-normalqueue")
public void receiveNormalQueue(String message)
{

    try {
        logger.info("message received in normal queue: " + message);
        throw new NullPointerException();

    } catch (Exception e) {

        logger.error(LoggingUtil.getStackTrace(e));;
    }

}

即使异常消息没有返回队列。

@Bean
public DefaultJmsListenerContainerFactory jmsListenerContainerFactory() {
    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
    factory.setConnectionFactory(getSQSConnectionFactory());
    factory.setConcurrency("1-2");
    factory.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);
    return factory;
}

Answer 1

您必须使用 DMLC 的交易。

使用 Session.AUTO_ACKNOWLEDGE 和 setSessionTransacted(true)。

如果监听器正常退出，则消息被移除。如果监听器抛出异常，则消息将回滚到队列中。

您也可以使用客户端模式处理事务，但您必须自己确认成功的消息。

您不必使用带有 SimpleMessageListenerContainer 的事务，但您仍然必须抛出异常才能使消息重新排队。