如何使用 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 可以是以下选项之一:useConstant、useExchangeId、使用属性值。对于 usePropertyValue 选项,将使用 属性 CamelAwsMessageGroupId 的值。
我们可以使用 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 可以是以下选项之一:useConstant、useExchangeId、使用属性值。对于 usePropertyValue 选项,将使用 属性 CamelAwsMessageGroupId 的值。