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

Reply via email to