如何使用Amazon SQS Springn cloud annotation@SqsListener轮询特定数量的消息

Question

需要：一次轮询/监听10条消息（具体计数不基于轮询时间）使用Spring cloud的现有代码库aws消息轮询基于默认时间。现在需要根据消息的计数进行轮询。

寻找与下面代码类似的基于注释的配置方法

@SqsListener(value = "xxx-sqs",deletionPolicy = ON_SUCCESS)
public void auditProcessor(String json) throws IOException {
    log.info("*********** Inside Listner***********");
    log.info("JSON Data "+json);
}

对此的任何帮助都将不胜感激。

Answer 1

可以在SimpleMessageListenerContainerFactory中配置从SQS请求的消息量。

也就是说，SQS的工作方式是，即使你要求10条消息，你也不能保证即使队列中有更多消息，你也会得到10条。你只能确定你不会得到超过10个。