Intercepting all messages that flow through NMR

[hkapoor]

Hi,

I have to interceptall messages that flow through NMR For this I have done the following.

I have created a class called EchoAll as follows:

import org.apache.servicemix.nmr.api.event.ExchangeListener;

import org.apache.servicemix.nmr.api.Exchange;

public class EchoAll implements ExchangeListener {

    public void exchangeSent(Exchange exchange) {System.out.println("EXCHANGE SENT");}

    public void exchangeDelivered(Exchange exchange) {System.out.println("EXCHANGE DELIVERED");}

    public void exchangeFailed(Exchange exchange) {System.out.println("EXCHANGE FAILED");}

}

I compiled and packaged the above class in to InterceptAll.jar.

I then placed  InterceptAll.jar file in fuse-esb-4.0.0.4\lib folder.

I then created EchoAll.xml with the following content:

I placed the above EchoAll.xml in fuse-esb-4.0.0.4\deploy folder and restarted Fuse.

When I give "osgi list" command I am able to see EchoAll.xml however When I invoke cxf-wsdl-first example (from fuse-esb-4.0.0.4\examples\cxf-wsdl-first folder) through its client. I do not get any of EXCHANGE SENT, EXCHANGE DELIVERED, EXCHANGE FAILED.

Please Help!!

-Harshit

[joe.luo]

Firstly, I can see a small typo in your EchoAll.xml where you defined the bean id as "myListener" but you referenced it in osgi:service as "myListner". I am not sure if it is the root cause of your problem though.

If correcting the typo still does not solve your problem, could you attach your test case please?

[jgoodyea]

Hi All,

As a heads up we have an Exchange and an Endpoint Listener demo available in the SMX4 NMR kit: http://servicemix.apache.org/nmr/servicemix-nmr-100.html

I haven't tried it with the cxf-wsdl-first example however I have noticed that for some demos I will not see output from the listener. This is due to the particular example not sending/receiving exchanges on the NMR. The bridge example does provide a very good demonstration of NMR exchanges using the ExchangeListener.

For comparison purposes here is the beans.xml content from the demo:

Cheers,

Jamie

http://icodebythesea.blogspot.com/

Edited by: jgoodyea on Apr 2, 2009 1:55 PM

[hkapoor]

Hi,

There were 2 problems,

1) The spelling of myListener was different in

          bean id="myListener" and

          =0.0.0))

-Harshit

[jgoodyea]

Hi,

Could you post some of your pom file for building this listener bundle?

Here is a link to the pom file used to build the NMR exchange listener example for comparison purposes:

http://fisheye6.atlassian.com/browse/~raw,r=756486/servicemix/smx4/nmr/trunk/examples/interceptors/exchange/pom.xml

Cheers,

Jamie

http://icodebythesea.blogspot.com/

[hkapoor]

I did not use any pom file to create bundle. I am under the impression that bundle will be generated automatically, infact it does get generated in /data/bundles generated folder.

-Harshit

[hkapoor]

Hi,

After combining a couple of sample codes and pom.xml I have managed to get the Interceptor working. The attached file contains every thing. Use mvn install to create a package and then deploy it using osgi install jbi:... command.

Have a look at "STEPS README.txt" in the zip file for more details

-Harshit

[jgoodyea]

Hi,

I just tried out your interceptor demo, nice work

In case anyone else reading this thread is interested in learning more about the interceptors in Servicemix please see:

http://servicemix.apache.org/SMX4NMR/9-interceptors.html

http://servicemix.apache.org/SMX4NMR/10-events.html

Cheers,

Jamie

http://icodebythesea.blogspot.com/