即使出现异常，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 的事务，但您仍然必须抛出异常才能使消息重新排队。

Answer 2

只有当侦听器停止并与代理断开连接时，消息才会返回队列，您所描述的行为是在 DefaultMessageListenerContainer 的客户端上，它将消息发送到您的侦听器并管理异常和重试，代理不知道在这些处理中，他只知道这些消息已发送给客户端并正在等待确认。 如果在 MessageConsumer 的实现上存在重置或重启等方法，则取决于 SQS 方法和功能。 您可以尝试 jms 会话的恢复（）方法，但我认为这只会在客户端重新启动交付。 https://docs.oracle.com/javaee/7/api/javax/jms/Session.html#recover--

这是一个不好的做法，但是如果您重新启动连接或 DefaultMessageListenerContainer，未确认的消息会返回到代理并重新启动传递。