Camel gang: I'm using the Camel CXFRS support to publish a REST service using Camel. What I want is for the incoming request to actually invoke my service class, and the response from that to go into the Camel route for further processing. That appears to happen just fine when using the performInvocation=true option, BUT... when I do that, it appears that the method on the resource class is called twice for each incoming REST call.
My beans.xml looks like this: ------------------------------------------------- <?xml version="1.0" ?> <beans xmlns="http://www.springframework.org/schema/beans"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xmlns:camel="http://camel.apache.org/schema/spring"; xmlns:cxf="http://camel.apache.org/schema/cxf"; xmlns:jaxrs="http://cxf.apache.org/jaxrs"; xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd http://camel.apache.org/schema/cxf http://camel.apache.org/schema/cxf/camel-cxf.xsd http://cxf.apache.org/jaxrs http://cxf.apache.org/schemas/jaxrs.xsd";> <bean id="myTypeConverter" class="com.fogbeam.exp.camel.cxfrs.typeconverter.MyTypeConverter" /> <!-- <bean id="jsonProvider" class="org.apache.cxf.jaxrs.provider.json.JSONProvider" /> --> <bean id="jsonProvider" class="org.codehaus.jackson.jaxrs.JacksonJaxbJsonProvider" /> <cxf:rsServer id="rsServer" address="http://localhost:9090/CxfRsRouterTest/route"; serviceClass="com.fogbeam.exp.camel.cxfrs.jaxrs.beans.CustomerService" loggingFeatureEnabled="true" loggingSizeLimit="20"> <cxf:providers> <ref bean="jsonProvider" /> </cxf:providers> </cxf:rsServer> <!-- The camel route context --> <camel:camelContext id="camelContext"> <camel:route> <camel:from uri="cxfrs:bean:rsServer?performInvocation=true" /> <camel:to uri="log:body?level=INFO" /> <camel:to uri="file:data/outbox" /> </camel:route> </camel:camelContext> </beans> ------------------------------------------------------- and the Java code for the class in question looks like this: ------------------------------------------------------------------------------- @Path("/customerservice/") @Consumes( MediaType.APPLICATION_JSON ) @Produces( MediaType.APPLICATION_JSON ) public class CustomerService { private static long invocationCount = 0; Map<Long, Customer> customers = new HashMap<Long, Customer>(); @POST @Path("/customers/") public Customer insertCustomer(Customer customer) { System.out.println( "invocationCount: " + (invocationCount++)); System.out.println("----------------\ninvoking insertCustomer, Customer name is: " + customer.getName() + "\n*********************************************" ); customers.put(customer.getId(), customer); return customer; } } --------------------------------------------------------------------------------------- When I run this, the Camel process logs as follows: Mar 19, 2016 9:32:30 PM org.apache.cxf.endpoint.ServerImpl initDestination INFO: Setting the server's publish address to be http://localhost:9090/CxfRsRouterTest/route Mar 19, 2016 9:32:55 PM org.apache.cxf.interceptor.LoggingInInterceptor INFO: Inbound Message ---------------------------- ID: 1 Address: http://localhost:9090/CxfRsRouterTest/route/customerservice/customers Encoding: UTF-8 Http-Method: POST Content-Type: application/json Headers: {accept-encoding=[gzip,deflate], connection=[keep-alive], Content-Length=[39], content-type=[application/json], Host=[localhost:9090], User-Agent=[CxfRSClientMain]} Payload: { "id":"123", "name" -------------------------------------- invocationCount: 0 ---------------- invoking insertCustomer, Customer name is: Phillip Rhodes ********************************************* invocationCount: 1 ---------------- invoking insertCustomer, Customer name is: Phillip Rhodes ********************************************* Mar 19, 2016 9:32:56 PM org.apache.cxf.interceptor.LoggingOutInterceptor INFO: Outbound Message --------------------------- ID: 1 Response-Code: 200 Content-Type: application/json Headers: {Content-Type=[application/json], Date=[Sun, 20 Mar 2016 01:32:55 GMT]} Messages: (message truncated to 20 bytes) Payload: {"id":123,"name":"Ph -------------------------------------- This behavior seems wrong to me. I wouldn't expect my service method to be called twice when somebody hits the REST endpoint. Can anybody confirm if this is invalid, and if so, comment if there's a way to fix this? Or is it a bug in Camel or CXF? Any and all help is much appreciated. This is using Camel 2.16.2, FWIW. Also, there's a question up on StackOverflow from somebody having what appears to be the same issue. http://stackoverflow.com/questions/35958121/apache-camel-cxfrsendpoint-performinvocation-setting-triggers-invokation-twice Thanks, Phil --- This message optimized for indexing by NSA PRISM
