java - 如何使用 Camel 在 AWS sqs 上发送消息属性和消息正文？

Question

我想使用 Camel 路由将一些消息属性以及消息正文发送到AWS sqs。但只有消息正文被发送。我无法向 SQS 发送消息属性。以下是我的路线

from("direct:send-to-sqs")
                .setBody(simple("${exchangeProperty.ENTITY_JSON}"))
                .setProperty("systemName",simple("FINANCE"))
                .log("body which is to be send to sqs is ${body}")
                .to("aws-sqs://{my sqs url}:QueueForPOC?" +
                        "amazonSQSClient=#sqsClient&attributeNames=#systemName")
                .log("entity has been sent to SQS.");

任何人都可以给我一些线索和帮助吗？

Answer 1

尝试使用setHeader而不是setProperty