spring - 使用@MessageMapping 注解时如何以编程方式启动/停止消息消费？

Question

我正在使用@MessageMapping(queue_name)注释和 spring-aws-cloud 库来使用来自两个 SQS 队列的消息。

我看到它SimpleMessageListenerContainer被用作两个消息队列的侦听器容器。容器上有一个start()和一个stop()方法，但我相信这将启动/停止两个队列的消费。

我想知道是否有办法以编程方式分别启动/停止队列的队列消耗。怎样才能做到这一点？

Answer 1

以编程方式启动和停止单个队列的使用start(queueName)和stop(queueName)功能。SimpleMessageListenerContainer

Answer 2

您需要为每个队列使用单独的容器来独立启动/停止侦听。

快速浏览一下代码，在我看来，使用注解创建侦听器时只有一个侦听器容器。

我建议您在GitHub中打开问题/功能建议；我建议您将问题编号发回此处，以便感兴趣的各方可以关注讨论。