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
> >>>
> >>>
> >>>
> >>>
> >>>
> >
> >
> >
>
