hi,
I'm using camel-sqs component, and I need to SET message attributes
when sending messages to SQS.
I tried:
....
process(new Processor() {
@Override
public void process(Exchange exchange) throws Exception {
Message in = exchange.getIn();
Map<String, String> msgAttrs = new HashMap<String, String>();
msgAttrs.put("my-attr-1", "value-1");
msgAttrs.put("my-attr-2", "value-2");
in.setHeader("CamelAwsSqsMessageAttributes", msgAttrs);
}
}).
to("aws-sqs://.....").
but no luck.
the header field CamelAwsSqsMessageAttributes arrives empty {} on the
other side.
is there any way to set the message attributes?
thanks in advance,
Cesar