Hi

When sending to sqs, then any header by default is sent along, unless
its filtered out. You get a WARN log if a header is dropped.

So try just setting those 2 headers directly as Camel Message headers.




On Wed, Feb 4, 2015 at 9:29 PM, Cesar Devera <cesar.dev...@movile.com> wrote:
> 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



-- 
Claus Ibsen
-----------------
Red Hat, Inc.
Email: cib...@redhat.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen
hawtio: http://hawt.io/
fabric8: http://fabric8.io/

Reply via email to