使用@SqsListener注释为FIFO配置消息组ID

Question

我使用了Spring cloud API提供的@SqsListener来消费FIFO队列中的消息。我想使用基于特定消息组ID的消息。不确定在何处配置此设置。

我试图阅读AWS spring cloud文档，并在谷歌上做了一些搜索，但找不到答案或示例。

我的注解如下所示：

@SqsListener(value = orderQueue, deletionPolicy = SqsMessageDeletionPolicy.ON_SUCCESS)

我有以下SQS配置：

        public QueueMessagingTemplate queueMessagingTemplate(AmazonSQSAsync amazonSQSAsync) {
            return new QueueMessagingTemplate(amazonSQSAsync);
        }

并使用以下依赖关系：

            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-aws</artifactId>
            <version>2.0.0.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-aws-messaging</artifactId>
            <version>2.0.0.RELEASE</version>
        </dependency>

我主要在寻找如何配置@SqsListener根据消息组Id读取消息的答案。

Answer 1

我不认为即使是AWS sdk也提供了通过其groupId消费消息的方法。groupId基本上只是一种在先进先出队列中构建消息集群的机制。然后，保证集群内的消息按照发送的顺序进行传递。