You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@camel.apache.org by Phillip Rhodes <mo...@gmail.com> on 2016/03/20 02:53:53 UTC
Camel CXF-RS resource method called twice when using performInvocation
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
Re: Camel CXF-RS resource method called twice when using
performInvocation
Posted by "Walzer, Thomas" <th...@integratix.net>.
Hi,
For this kind of question please use the users mailing list.
http://camel.apache.org/mailing-lists.html
Cheers, Thomas.
> Am 20.03.2016 um 02:54 schrieb Phillip Rhodes <mo...@gmail.com>:
>
> 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