我想使用骆驼路由将一些消息属性以及消息正文发送到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.");谁能给我一些线索和帮助吗?
添加回答
举报
0/150
提交
取消