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
