如何使用 camel-aws 将消息 MessageGroupID 和 MessageDeduplicationID 发送到 amazonSQS

How to send a message MessageGroupID and MessageDeduplicationID to amazonSQS using camel-aws

我们可以使用 Java-DSL 语法向 Amazon SQS "FIFO" 队列发送消息吗:

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

请记住:这是一个 FIFO 队列,因此它需要 MessageGroupID 和 MessageDeduplicationID。

尝试使用以下语法:

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

其中 STRATEGY 可以是以下选项之一:useConstantuseExchangeId使用属性值。对于 usePropertyValue 选项,将使用 属性 CamelAwsMessageGroupId 的值。

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