Rabbit mQ 消息从就绪队列移动到 Unack 队列

Question

我有一个单独的发布者和消费者。我启动发布者并发布消息。现在我启动消费者，问题是消息从就绪队列移动到取消确认队列，将消息标记为重新传递，这是我想要避免的。所以我想要什么仅当我发送 ack 而不是在消费者重启或启动时才应将其标记为重新发送

配置：

@Bean
public org.springframework.amqp.rabbit.connection.Connection mqConnection() {
    CloudFactory cloudFactory = new CloudFactory();
    Cloud cloud = cloudFactory.getCloud();
    return cloud.getServiceConnector("mqservicename", ConnectionFactory.class,
            null).createConnection();
} 
@Bean
public StatefulRetryOperationsInterceptor interceptor() {
        return RetryInterceptorBuilder.stateful().retryOperations(retryTemplate()).recoverer(new RejectAndDontRequeueRecoverer())

            .build();
}
@Bean
public SimpleMessageListenerContainer listenerContainer() {
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
    container.setMessageListener(new MessageListenerAdapter());
    container.setAdviceChain(new Advice[] {
           interceptor()
    });

    return container;
}



@Bean
public RetryTemplate retryTemplate(){
    Map map=new HashMap<Class<? extends Throwable>, Boolean>();
    map.put(CustomException.class, true);
    RetryTemplate retryTemplate=new RetryTemplate();
    retryTemplate.setRetryPolicy(new SimpleRetryPolicy(3,map));
    return retryTemplate;
}

Answer 1

如果您使用的是 Spring AMQP，则需要在提出此类问题时显示您的配置。

如果您将确认模式设置为手动，则您需要对确认负责。阅读the documentation。对于AUTO ackmode，当监听器正常返回时，容器会确认消息。