java - Spring-Boot/AMQP - 限制处理的消息数量

Question

我有一个使用 spring-boot AMQP 库的 spring-boot 应用程序。

pom.xml:

<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

如何让它处理并确认单个消息，然后正常退出？

可以让它在没有确认的情况下退出，但似乎无法弄清楚如何确认消息然后退出!

Answer 1

您可以简单地使用 RabbitTemplate.receive() (或 receiveAndConvert())方法之一，而不是使用监听器容器。