Настройте идентификатор группы сообщений для FIFO с помощью аннотации @SqsListener - PullRequest
Новая
       30

Настройте идентификатор группы сообщений для FIFO с помощью аннотации @SqsListener

0 голосов
/ 07 июня 2019

Я использую @SqsListener, предоставленный Spring Cloud API, для получения сообщений из очереди FIFO.Я хочу использовать сообщения на основе определенного идентификатора группы сообщений.Не уверен, где настроить этот параметр.

Я пытался прочитать документацию по облачным сервисам AWS Spring и запустил Google, но не могу найти ответ или пример.

Моя аннотация выглядит так: 

@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 для чтениясообщения на основе идентификатора группы сообщений.

...