OK, this is what I have so far. It is not working (doesn't raise an error, just doesn't give any output), but before I do much more troubleshooting, I want to make sure that I am not doing anything obviously wrong.
To review, what I am trying to do with Camel is: 1.) Send ten numbers into a queue, 1-10. 2.) For each number, call a "doubleit" web service that will double the number. (The wsdl is here[1] and it is running on Tomcat) 3.) Write the doubled number out to a file. To do this, I am modifying the walk-through example[2] (which works fine on my machine), which goes directly from queue to file, and inserting the web service call in the middle. Here are the only real changes from [2]: private static final String JAXWS_SERVER_ADDRESS = "http://localhost:8080/doubleit/services/doubleit";; private static final String SERVICE_CLASS = "com.mycompany.webservice.service.DoubleItPortTypeImpl"; private static final String CXF_URI = "cxf://" + JAXWS_SERVER_ADDRESS + "?serviceClass=" + SERVICE_CLASS; context.addRoutes(new RouteBuilder() { public void configure() { from("test-jms:queue:test.queue").to(CXF_URI).to("file://test"); from(CXF_URI).process(new Processor() { public void process(Exchange e) { final List<String> params = new ArrayList<String>(); System.out.println("This was called!"); // never gets called e.getIn().setHeader(CxfConstants.OPERATION_NAME,"DoubleIt"); params.add(e.getIn().getBody(String.class)); e.getIn().setBody(params); } }); from("file://test").process(new Processor() { public void process(Exchange e) { System.out.println("Received exchange: " + e.getIn()); } }); } }); Does anyone see anything I am doing wrong here? Note debugging is showing that the process() attached to CXF_URI is never being called--so I may not be attaching things correctly. BTW, if it matters, my DoubleItPortTypeImpl is here[3]. Thanks for any help, Glen [1] http://www.jroller.com/gmazza/date/20080417#WFstep5 [2] http://tinyurl.com/4dn6c6 [3] http://www.jroller.com/gmazza/date/20080417#WFstep6 2008-04-09 Willem Jiang wrote: > Hi Glen, > > From your requirement , you need to start a "DoubleIt" web service your > self, maybe the same time that Camel context start. > > Here is the code snippet for setting up the router. > > from("test-jms:queue:test.queue").to("cxf://http://SERVICEADDRES?SEI=yourSEI...";).to("file://test"); > > If you just feed the queue with a series of numbers, you need to change > the message for the "DoubleIt" web service in a processer first. > Here is an example[1] to show you how to make a web service call by > setting the message header with the Web service operation name , and > message body with the parameters. You can get the result from the > exchange.getOut().getBody(), which is a list. > > [1]https://svn.apache.org/repos/asf/activemq/camel/trunk/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/CxfProducerTest.java > > Willem. > > > Glen Mazza wrote: > > Hello, > > > > I'm trying to create a Camel example so I can learn more about the > > product. What I'd like to do is feed a queue a series of numbers, which > > would automatically be fed as the lone parameter to a "DoubleIt" web > > service, the output of which (i.e., the input number doubled in value) > > would then be fed to a file. > > > > I understand how to write from a message queue to a file from this > > example[1], and also, the camel-cxf example[2] gives me a pretty good > > idea of how web service calls are made, but I'm not sure how to have a > > web service automatically activated based on what is fed through a > > queue; further, how to have the number that is fed into the queue serve > > as the lone parameter to that web service call (which component, if any, > > must occur between the queue and the web service so the number off the > > queue is put into the SOAP request.) Any guidance or known samples > > would be appreciated. > > > > Thanks, > > Glen > > > > [1] http://activemq.apache.org/camel/walk-through-an-example.html > > [2] http://activemq.apache.org/camel/cxf-example.html > > > > > > > > >
