Spring Rabbit：Acknowledge mode=Manual with RetryTemplate不会从队列中删除消息

Question

null

但它不会从Q1中删除消息。

public void onMessage(Message message, Channel channel) throws Exception {
        try {
            validateMessage();

            processMessage(message);
            channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
        }
        catch (DataValidationException ex){
            channel.basicReject(message.getMessageProperties().getDeliveryTag(),false);

        }
        catch(DownstreamAppException ex) {
            channel.basicReject(message.getMessageProperties().getDeliveryTag(),true);
            throw ex;
        }
    }

    void validMessage() {
        ..
        throw new DataValidationException();
    }

    void processMessage() {

        ...
        throw new DownstreamAppException();
    }

我不想请求验证失败的消息，但想请求那些由于下游应用程序失败而没有处理的消息进行重试。

几个问题：1。如果我没有在DownstreamAppException的catch中抛出异常，则消息不会抛出retryTemplate和Recoverer。是因为请求被拒绝的消息是一条新消息吗？

谢谢

Answer 1

当使用手动acks时（不管是否重试），您要负责ACK。如果您的代码永远无法访问，则消息（最终）将被请求；但您无法访问恢复器中的通道。

真正的问题是为什么要使用手动acks和ChannelAwareMessageListener？您的用例很简单。使用自动ackmode，容器将在成功时ack消息，并在任何异常时拒绝消息。

由于恢复程序重新发布消息，这被认为是成功的，并且消息将被容器ACK。