我想使用骆驼路由将一些消息属性以及消息正文发送到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.");
谁能给我一些线索和帮助吗?
慕容708150
相关分类