У меня есть небольшое приложение для весенней загрузки rabbitmq:
@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)....
Я вижу, что одно и то же сообщение отправляется несколько раз, прежде чем оно будет удалено из очереди.
Как я могу изменить эту конфигурацию, чтобы сообщение было отправлено ровно один раз.