Sending headers through NMR endpoints

[[e-mail]]

Hi, I have a problem with that piece of code:

from("nmr:xyz")

     .setHeader("test", constant("1"))

     .to("nmr:abc");

The message I receive in nmr:abc endpoint is without any headers.

My endpoint class receiving the message implements interface org.apache.servicemix.nmr.api.Endpoint.

Is any posibility to send headers to a nmr endpoint (or any other way among loosely coupled components)?

Or at least properties? I was trying to set properties with something like this:

from("nmr:xyz")

     .process(new Processor() {               

               public void process(Exchange exchange) throws Exception {                         

                    exchange.setProperty("Test", exchange.getExchangeId());

                    }

                    }).to("nmr:abc").to("log:foo?showAll=true&level=INFO");

but this property is not available in the component receiving data from nmr:abc endpoint (named abc) but it is available in logs, which are receiving a message from abc component. Moreover the exchange id is different in the abc component but in logs is the same as from nmr:xyz. It can be a reason, because the property is assigned to exchange, but how could I handle this?

I'd really like to be able to see headers (or at least properties) in the component receiving from the endpoint nmr:end.

Edited by: [e-mail] on Mar 5, 2010 11:57 AM

[davsclaus]

IMHO that sounds like a bug. It should be possible to pass headers, at least headers which can be serialized safely.

Can you create a bug in the Apache NMR JIRA tracker?

https://issues.apache.org/activemq/browse/SMX4NMR

[ffang]

Hi,

Already create SMX4-504[1] to track this issue

https://issues.apache.org/activemq/browse/SMX4-504

Freeman

[[e-mail]]

Hi,

I've copied files from SVN after Freeman Fang fixed it (https://issues.apache.org/activemq/browse/SMX4-504) but after recompilation and copy org.apache.servicemix.camel.component-4.2.0-fuse-01-00.jar file to Fuse ESB 4.2 it still won't work. Could You tell me what I'm doing wrong?

[ffang]

Hi,

Could you please tell me how you update the latest code? How you build it and how you override the old file?

1. you update code from apache svn repo or fuse svn repo?

2. you build the code based on trunk or released tag?

3. what's the artifacts name after you build?

4. where you copy the file to override the old one?

5. do you remove $SMX4_HOME/data folder after you override the old file?

Freeman

[[e-mail]]

I forgot about remove $SMX4_HOME/data folder. Now it works! Thank You very much

[lekkie_lomotayo]

Hi,

Please how can I get this update?