如何在Apache Camel中为AWS SQS FIFO队列设置MessageGroupId

当使用Apache Camel向AWS SQS FIFO队列发送消息时，必须指定MessageGroupId属性，但官方文档对此说明不够明确，以下是两种可行的实现方式：

方式一：通过消息头动态设置 #

如果需要为每条消息指定不同的分组ID，可在路由中给Exchange添加CamelAwsSqsMessageGroupId消息头：

from("direct:sqsFifoSender")
    .setHeader("CamelAwsSqsMessageGroupId", simple("${body.groupId}")) // 可根据消息内容动态生成
    .to("aws-sqs://your-fifo-queue.fifo?amazonSQSClient=#sqsClient");

方式二：通过端点参数固定配置 #

如果所有消息都使用同一个分组ID，可直接在SQS端点URI中配置messageGroupId参数：

from("direct:sqsFifoSender")
    .to("aws-sqs://your-fifo-queue.fifo?amazonSQSClient=#sqsClient&messageGroupId=order-processing-group");

关键注意点 #

• 确保SQS队列名称以.fifo结尾，这是AWS FIFO队列的强制命名规则
• 若同时设置了消息头和端点参数，消息头的优先级更高

内容的提问来源于stack exchange，提问作者Otavio Miguel