i want to send some message attributes to AWS sqs along with message body using camel routes. But only message body is getting sent. I am unable to send message attributes to SQS.Below is my route
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.");
Can anyone please give me some clue and help??
Try to use setHeader instead of setProperty
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With