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

我想使用骆驼路由将一些消息属性以及消息正文发送到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.");

谁能给我一些线索和帮助吗?


翻翻过去那场雪
浏览 58回答 1
1回答

慕容708150

尝试使用setHeader而不是setProperty
打开App,查看更多内容
随时随地看视频慕课网APP

相关分类

Java