Как отправить сообщение MessageGroupID и MessageDeduplicationID в amazonSQS с помощью camel-aws

Question

Можем ли мы отправить сообщение в очередь FIFO Amazon SQS с использованием синтаксиса Java-DSL:

from("..")..to("aws-sqs://testSQSFifo.fifo?amazonSQSClient=#amazonSQSClient);

Помните: это очередь FIFO, поэтому для нее нужны MessageGroupID и MessageDeduplicationID.

Answer 1

Попробуйте использовать следующий синтаксис:

from("..")..to("aws-sqs://testSQSFifo.fifo?amazonSQSClient=#amazonSQSClient&messageGroupIdStrategy=STRATEGY);

где СТРАТЕГИЯ может быть одним из следующих вариантов: useConstant, useExchangeId, usePropertyValue. Для параметра usePropertyValue будет использоваться значение свойства CamelAwsMessageGroupId.

см. https://github.com/apache/camel/blob/master/components/camel-aws-sqs/src/main/docs/aws-sqs-component.adoc