Spring AMQP 与 RabbitMQ 接收相同的消息

Question

我有小rabbitmq spring启动应用程序：

@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory)
{
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    factory.setAcknowledgeMode(AcknowledgeMode.AUTO);
    return factory;
}

简单队列定义：

@Bean
public Queue queue()
{
    return new Queue("queue");
}

以及记录消息的简单侦听器：

@RabbitHandler
public void process(@Payload Message message)....

我看到同一条消息在从队列中删除。

我如何更改此配置以确保消息只发送一次。

Answer 1

如果您的侦听器抛出异常，消息将重新排队并发送。

否则不能多次发送 - 不可能。

打开 DEBUG 日志记录以观察消息流。

Spring AMQP 与 RabbitMQ 接收相同的消息

Spring AMQP with RabbitMQ receiving same message

java

spring

spring-boot

rabbitmq

spring-amqp