OK, I've gotten logging better configured but still no luck--no file created with all the numbers doubled. Again, I'm trying to send 7 numbers to a queue, have them redirected to a web service call that doubles their numbers, and then writes to a file. I'm not getting any of the System.out() calls in my code output to the console, which indicates that not even the queue loading part is working (I had that working before... :( ).
Here's the logging file, source code, and debug output I'm getting: [1] http://glen.mazza.blog.googlepages.com/home I know the web service works (http://localhost:8080/doubleit/services/doubleit?wsdl returns the wsdl) Any idea what my next step should be? Also, I have some questions from Claus' response here: [2] https://issues.apache.org/activemq/browse/CAMEL-489?focusedCommentId=42542#action_42542 1.) How do I initialize the Dead Letter Channel--I don't think I'm getting one generated--also, where would it be created? 2.) When I code: .to("file://testfile.txt"). ..., where is testfile.txt supposed to be created--I'm guessing in the working directory where I'm running the app, correct? 3.) The input converter that Claus gave in [2] above, I may need when going from the web service result to the test file (because I assume the web service result is also an arraylist): ... .to(CXF_URI).to("file://testfile.txt").process(new Processor() { ... How do I attach the converter to this process (or all I need to do is just place the converter with its @Converter annotation in the source file and this will be done automatically?) Thanks, Glen 2008-05-01 Willem Jiang wrote: > Hi Glen, > > You just need to add the Integer 4 into the list. > Basically the camel-cxf producer (POJO data format)just call the > ClientImpl's [1] invoke method to call the real web service, and the > outgoing interceptor chain will help you do the parameter marshaling and > soap message creating work. > All you need to do is passing the operation parameters (which are same > with SEI defined) the into a list and set this list into the in message > body. > > In your case , the list element object's type should be Integer :) > > [1]https://svn.apache.org/repos/asf/incubator/cxf/trunk/rt/core/src/main/java/org/apache/cxf/endpoint/ClientImpl.java > > Willem. > > Glen Mazza wrote: > > Thanks Willem, I haven't been able to get back to this problem for > > awhile. I think I'm getting closer, although I haven't got the web > > service call to work properly yet. I think my next question is what the > > format of the web service call needs to be in the process method here: > > > > from("test-jms:queue:test.queue").process(new Processor() { > > public void process(Exchange e) { > > final List<String> params = new ArrayList<String>(); > > e.getIn().setHeader(CxfConstants.OPERATION_NAME,"DoubleIt"); > > params.add(e.getIn().getBody(String.class)); > > --> e.getIn().setBody(params); > > > > } > > }).to(CXF_URI)... > > > > > > For the DoubleIt web service call defined here: > > http://www.jroller.com/gmazza/date/20080417#WFstep5 > > > > How much of the web service request xml do I need to put in the > > setBody() above? I.e., if I want to double "4", do I need: > > > > 1.) 4 > > or > > 2.) <numberToDouble>4</numberToDouble> > > or > > 3.) <DoubleIt><numberToDouble>4</numberToDouble></DoubleIt> > > or > > 4.) <soap:body>....(#3 above)....</soap:body> > > > > Also, should I be using the List<String> above (i.e., adding #1 or #2 > > above to a List and then setting the body to that list?) Or should I > > just be calling e.getIn().setBody( /* a String object of #3 or #4 above > > */ )? > > > > Thanks, > > Glen > > > > > > > > 2008-04-21 Willem Jiang wrote: > > > >> Hi Glen, > >> > >> I think the router's code snippet should be > >> > >> from("test-jms:queue:test.queue").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); > >> > >> } > >> }).to(CXF_URI).to("file://test").process(new Processor() { > >> public void process(Exchange e) { > >> System.out.println("Received exchange: " + e.getIn()); > >> } > >> }); > >> > >> You need put the processor which deals with the CXF producer(client) > >> invocation parameter before the CXF producer. > >> > >> The dsl from(CXF_URI) will create a CXF consumer(server) which will listen > >> to the JAXWS_SERVER_ADDRESS that you specified in the CXF_URI. > >> > >> Willem. > >> > >> > >> Glen Mazza wrote: > >> > >>> 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 > >>>>> > >>>>> > >>>>> > >>>>> > >>>>> > >>>>> > >>> > >>> > > > > > > >
