CxfRsProducer is not thread safe
Locked
 
|
Hi all,
I am using Camel 2.10.0 deployed on Tomcat 7 and I try to test following scenario: 1. Have a CXF rest service deployed 2. Have a proxy CXF rest service over the service above, deployed under the same Camel instance It works fine, until I perform requests in parallel. Exception stacktrace is attached. stacktrace.txt I tried following things in class org.apache.camel.component.cxf.jaxrs.CxfRsProducer order to fix it: 1. Invoked JAXRSClientFactoryBean.setThreadSafe(true), with no success 2. Added synchronization point over line WebClient client = cfb.createWebClient(), from invokeHttpClient method. It works, but performance dropped on my localhost from 150 requests per second to 10 requests per second, so the fix is not acceptable. I attach my camel-config.xml - please let me know if additional info is needed.camel-config.xml I am not sure if the problem lies in the configuration I performed or in the cxf-rs component or in cxf itself. Any idea is appreciated. Best regards, Dumitru |
Re: CxfRsProducer is not thread safe
|
Hi
On 23/07/12 17:38, dumi_p wrote: > Hi all, > > I am using Camel 2.10.0 deployed on Tomcat 7 and I try to test following > scenario: > > 1. Have a CXF rest service deployed > 2. Have a proxy CXF rest service over the service above, deployed under the > same Camel instance > > It works fine, until I perform requests in parallel. Exception stacktrace is > attached. http://camel.465427.n5.nabble.com/file/n5716351/stacktrace.txt > stacktrace.txt > > I tried following things in class > org.apache.camel.component.cxf.jaxrs.CxfRsProducer order to fix it: > 1. Invoked JAXRSClientFactoryBean.setThreadSafe(true), with no success > 2. Added synchronization point over line WebClient client = > cfb.createWebClient(), from invokeHttpClient method. It works, but > performance dropped on my localhost from 150 requests per second to 10 > requests per second, so the fix is not acceptable. > > I attach my camel-config.xml - please let me know if additional info is > needed. http://camel.465427.n5.nabble.com/file/n5716351/camel-config.xml > camel-config.xml > > I am not sure if the problem lies in the configuration I performed or in the > cxf-rs component or in cxf itself. > > Any idea is appreciated. > Willem can you comment on this please ? This looks suspicious. The trace shows that the thread safety is compromised at the point of creating web clients. I can work on a patch - though will take me a bit of time to get to it Dumitru - any chance you can declare jaxrs:client or WebClient [1,2] explicitly, with a thread safe flag set and reuse it in the routes directly ? That should do it. Thanks Sergey [1] http://cxf.apache.org/docs/jax-rs-client-api.html#JAX-RSClientAPI-ConfiguringHTTPclientsinSpring [2] http://cxf.apache.org/docs/jax-rs-client-api.html#JAX-RSClientAPI-ConfiguringproxiesinSpring [2] > Best regards, > Dumitru > > > > -- > View this message in context: http://camel.465427.n5.nabble.com/CxfRsProducer-is-not-thread-safe-tp5716351.html > Sent from the Camel - Users mailing list archive at Nabble.com. |
Re: CxfRsProducer is not thread safe
|
On Tue, Jul 24, 2012 at 6:16 AM, Sergey Beryozkin <[hidden email]>wrote:
> Hi > > On 23/07/12 17:38, dumi_p wrote: > >> Hi all, >> >> I am using Camel 2.10.0 deployed on Tomcat 7 and I try to test following >> scenario: >> >> 1. Have a CXF rest service deployed >> 2. Have a proxy CXF rest service over the service above, deployed under >> the >> same Camel instance >> >> It works fine, until I perform requests in parallel. Exception stacktrace >> is >> attached. http://camel.465427.n5.nabble.**com/file/n5716351/stacktrace.* >> *txt <http://camel.465427.n5.nabble.com/file/n5716351/stacktrace.txt> >> stacktrace.txt >> >> I tried following things in class >> org.apache.camel.component.**cxf.jaxrs.CxfRsProducer order to fix it: >> 1. Invoked JAXRSClientFactoryBean.**setThreadSafe(true), with no success >> 2. Added synchronization point over line WebClient client = >> cfb.createWebClient(), from invokeHttpClient method. It works, but >> performance dropped on my localhost from 150 requests per second to 10 >> requests per second, so the fix is not acceptable. >> >> I attach my camel-config.xml - please let me know if additional info is >> needed. http://camel.465427.n5.nabble.**com/file/n5716351/camel-** >> config.xml<http://camel.465427.n5.nabble.com/file/n5716351/camel-config.xml> >> camel-config.xml >> >> I am not sure if the problem lies in the configuration I performed or in >> the >> cxf-rs component or in cxf itself. >> >> Any idea is appreciated. >> >> Well,I look at the code and see some JAXRSClientFactoryBean cache - > Willem can you comment on this please ? This looks suspicious. > I don't like the JAXRSClientFactoryBean cache either, it is used to create the WebClient if we change the URI per request. Now I just want to ask if there is a way to override the server address by setting the context per request in the WebClient. If So , it could easy for use to resolve the issue. > The trace shows that the thread safety is compromised at the point of > creating web clients. I can work on a patch - though will take me a bit of > time to get to it > > Dumitru - any chance you can declare jaxrs:client or WebClient [1,2] > explicitly, with a thread safe flag set and reuse it in the routes directly > ? That should do it. > > Thanks > Sergey > > [1] http://cxf.apache.org/docs/**jax-rs-client-api.html#JAX-**RSClientAPI- > **ConfiguringHTTPclientsinSpring<http://cxf.apache.org/docs/jax-rs-client-api.html#JAX-RSClientAPI-ConfiguringHTTPclientsinSpring> > [2] http://cxf.apache.org/docs/**jax-rs-client-api.html#JAX-**RSClientAPI- > **ConfiguringproxiesinSpring<http://cxf.apache.org/docs/jax-rs-client-api.html#JAX-RSClientAPI-ConfiguringproxiesinSpring> > [2] > > > Best regards, >> Dumitru >> >> >> >> -- >> View this message in context: http://camel.465427.n5.nabble.** >> com/CxfRsProducer-is-not-**thread-safe-tp5716351.html<http://camel.465427.n5.nabble.com/CxfRsProducer-is-not-thread-safe-tp5716351.html> >> Sent from the Camel - Users mailing list archive at Nabble.com. >> > > |
Re: CxfRsProducer is not thread safe
|
|
Dumitru,
I'm not seeing in http://camel.465427.n5.nabble.com/file/n5716351/camel-config.xml how the route is initiated, can you provide the source of the updated org.apache.camel.example.cxf.CamelRoute ? I've updated one of the tests which Willem created to get 500 threads stressing the rs client code, can not reproduce the issue Cheers, Sergey On 24/07/12 02:45, Willem Jiang wrote: > On Tue, Jul 24, 2012 at 6:16 AM, Sergey Beryozkin<[hidden email]>wrote: > >> Hi >> >> On 23/07/12 17:38, dumi_p wrote: >> >>> Hi all, >>> >>> I am using Camel 2.10.0 deployed on Tomcat 7 and I try to test following >>> scenario: >>> >>> 1. Have a CXF rest service deployed >>> 2. Have a proxy CXF rest service over the service above, deployed under >>> the >>> same Camel instance >>> >>> It works fine, until I perform requests in parallel. Exception stacktrace >>> is >>> attached. http://camel.465427.n5.nabble.**com/file/n5716351/stacktrace.* >>> *txt<http://camel.465427.n5.nabble.com/file/n5716351/stacktrace.txt> >>> stacktrace.txt >>> >>> I tried following things in class >>> org.apache.camel.component.**cxf.jaxrs.CxfRsProducer order to fix it: >>> 1. Invoked JAXRSClientFactoryBean.**setThreadSafe(true), with no success >>> 2. Added synchronization point over line WebClient client = >>> cfb.createWebClient(), from invokeHttpClient method. It works, but >>> performance dropped on my localhost from 150 requests per second to 10 >>> requests per second, so the fix is not acceptable. >>> >>> I attach my camel-config.xml - please let me know if additional info is >>> needed. http://camel.465427.n5.nabble.**com/file/n5716351/camel-** >>> config.xml<http://camel.465427.n5.nabble.com/file/n5716351/camel-config.xml> >>> camel-config.xml >>> >>> I am not sure if the problem lies in the configuration I performed or in >>> the >>> cxf-rs component or in cxf itself. >>> >>> Any idea is appreciated. >>> >>> Well,I look at the code and see some JAXRSClientFactoryBean cache - >> Willem can you comment on this please ? This looks suspicious. >> > > I don't like the JAXRSClientFactoryBean cache either, it is used to > create the WebClient if we change the URI per request. Now I just want to > ask if there is a way to override the server address by setting the context > per request in the WebClient. > > If So , it could easy for use to resolve the issue. > > >> The trace shows that the thread safety is compromised at the point of >> creating web clients. I can work on a patch - though will take me a bit of >> time to get to it >> >> Dumitru - any chance you can declare jaxrs:client or WebClient [1,2] >> explicitly, with a thread safe flag set and reuse it in the routes directly >> ? That should do it. >> >> Thanks >> Sergey >> >> [1] http://cxf.apache.org/docs/**jax-rs-client-api.html#JAX-**RSClientAPI- >> **ConfiguringHTTPclientsinSpring<http://cxf.apache.org/docs/jax-rs-client-api.html#JAX-RSClientAPI-ConfiguringHTTPclientsinSpring> >> [2] http://cxf.apache.org/docs/**jax-rs-client-api.html#JAX-**RSClientAPI- >> **ConfiguringproxiesinSpring<http://cxf.apache.org/docs/jax-rs-client-api.html#JAX-RSClientAPI-ConfiguringproxiesinSpring> >> [2] >> >> >> Best regards, >>> Dumitru >>> >>> >>> >>> -- >>> View this message in context: http://camel.465427.n5.nabble.** >>> com/CxfRsProducer-is-not-**thread-safe-tp5716351.html<http://camel.465427.n5.nabble.com/CxfRsProducer-is-not-thread-safe-tp5716351.html> >>> Sent from the Camel - Users mailing list archive at Nabble.com. >>> >> >> > |
Re: CxfRsProducer is not thread safe
|
|
As a sanity check I've run the multi-threaded test on the trunk and
2.9.x due to diff CXF versions being used there, still things work OK. Dumitru, I've been telling everyone CXF RS producer is broken :-), so need your help with reproducing the case. Are you having multiple threads running within a route builder itself ? Please provide more info Sergey On 25/07/12 14:44, Sergey Beryozkin wrote: > Dumitru, > > I'm not seeing in > http://camel.465427.n5.nabble.com/file/n5716351/camel-config.xml > how the route is initiated, can you provide the source of the updated > org.apache.camel.example.cxf.CamelRoute ? > > I've updated one of the tests which Willem created to get 500 threads > stressing the rs client code, can not reproduce the issue > > Cheers, Sergey > > On 24/07/12 02:45, Willem Jiang wrote: >> On Tue, Jul 24, 2012 at 6:16 AM, Sergey >> Beryozkin<[hidden email]>wrote: >> >>> Hi >>> >>> On 23/07/12 17:38, dumi_p wrote: >>> >>>> Hi all, >>>> >>>> I am using Camel 2.10.0 deployed on Tomcat 7 and I try to test >>>> following >>>> scenario: >>>> >>>> 1. Have a CXF rest service deployed >>>> 2. Have a proxy CXF rest service over the service above, deployed under >>>> the >>>> same Camel instance >>>> >>>> It works fine, until I perform requests in parallel. Exception >>>> stacktrace >>>> is >>>> attached. >>>> http://camel.465427.n5.nabble.**com/file/n5716351/stacktrace.* >>>> *txt<http://camel.465427.n5.nabble.com/file/n5716351/stacktrace.txt> >>>> stacktrace.txt >>>> >>>> I tried following things in class >>>> org.apache.camel.component.**cxf.jaxrs.CxfRsProducer order to fix it: >>>> 1. Invoked JAXRSClientFactoryBean.**setThreadSafe(true), with no >>>> success >>>> 2. Added synchronization point over line WebClient client = >>>> cfb.createWebClient(), from invokeHttpClient method. It works, but >>>> performance dropped on my localhost from 150 requests per second to 10 >>>> requests per second, so the fix is not acceptable. >>>> >>>> I attach my camel-config.xml - please let me know if additional info is >>>> needed. http://camel.465427.n5.nabble.**com/file/n5716351/camel-** >>>> config.xml<http://camel.465427.n5.nabble.com/file/n5716351/camel-config.xml> >>>> >>>> camel-config.xml >>>> >>>> I am not sure if the problem lies in the configuration I performed >>>> or in >>>> the >>>> cxf-rs component or in cxf itself. >>>> >>>> Any idea is appreciated. >>>> >>>> Well,I look at the code and see some JAXRSClientFactoryBean cache - >>> Willem can you comment on this please ? This looks suspicious. >>> >> >> I don't like the JAXRSClientFactoryBean cache either, it is used to >> create the WebClient if we change the URI per request. Now I just want to >> ask if there is a way to override the server address by setting the >> context >> per request in the WebClient. >> >> If So , it could easy for use to resolve the issue. >> >> >>> The trace shows that the thread safety is compromised at the point of >>> creating web clients. I can work on a patch - though will take me a >>> bit of >>> time to get to it >>> >>> Dumitru - any chance you can declare jaxrs:client or WebClient [1,2] >>> explicitly, with a thread safe flag set and reuse it in the routes >>> directly >>> ? That should do it. >>> >>> Thanks >>> Sergey >>> >>> [1] >>> http://cxf.apache.org/docs/**jax-rs-client-api.html#JAX-**RSClientAPI- >>> **ConfiguringHTTPclientsinSpring<http://cxf.apache.org/docs/jax-rs-client-api.html#JAX-RSClientAPI-ConfiguringHTTPclientsinSpring> >>> >>> [2] >>> http://cxf.apache.org/docs/**jax-rs-client-api.html#JAX-**RSClientAPI- >>> **ConfiguringproxiesinSpring<http://cxf.apache.org/docs/jax-rs-client-api.html#JAX-RSClientAPI-ConfiguringproxiesinSpring> >>> >>> [2] >>> >>> >>> Best regards, >>>> Dumitru >>>> >>>> >>>> >>>> -- >>>> View this message in context: http://camel.465427.n5.nabble.** >>>> com/CxfRsProducer-is-not-**thread-safe-tp5716351.html<http://camel.465427.n5.nabble.com/CxfRsProducer-is-not-thread-safe-tp5716351.html> >>>> >>>> Sent from the Camel - Users mailing list archive at Nabble.com. >>>> >>> >>> >> |
|
|
Hi Sergey,
Sorry for the late response, I could not work today on the issue - other things to do :-(. I will reproduce it tomorrow and send you the full code, together with the JMX for JMeter load test.
Note in my test, with 10 concurrent threads it was failing on more than 20 percent of the requests. Best regards, /Dumitru
On Wed, Jul 25, 2012 at 7:41 PM, Sergey Beryozkin-3 [via Camel] <[hidden email]> wrote:
|
Re: CxfRsProducer is not thread safe
|
|
Dumitru do you mind to create a JIRA[1] here.
It will be helpful for us to trace the issue. [1]https://issues.apache.org/jira/browse/CAMEL Willem On Thu, Jul 26, 2012 at 2:55 AM, dumi_p <[hidden email]> wrote: > Hi Sergey, > > Sorry for the late response, I could not work today on the issue - other > things to do :-(. I will reproduce it tomorrow and send you the full code, > together with the JMX for JMeter load test. > > Note in my test, with 10 concurrent threads it was failing on more than 20 > percent of the requests. > > Best regards, > /Dumitru > > On Wed, Jul 25, 2012 at 7:41 PM, Sergey Beryozkin-3 [via Camel] < > [hidden email]> wrote: > >> As a sanity check I've run the multi-threaded test on the trunk and >> 2.9.x due to diff CXF versions being used there, still things work OK. >> >> Dumitru, I've been telling everyone CXF RS producer is broken :-), so >> need your help with reproducing the case. Are you having multiple >> threads running within a route builder itself ? Please provide more info >> >> Sergey >> On 25/07/12 14:44, Sergey Beryozkin wrote: >> >> > Dumitru, >> > >> > I'm not seeing in >> > http://camel.465427.n5.nabble.com/file/n5716351/camel-config.xml >> > how the route is initiated, can you provide the source of the updated >> > org.apache.camel.example.cxf.CamelRoute ? >> > >> > I've updated one of the tests which Willem created to get 500 threads >> > stressing the rs client code, can not reproduce the issue >> > >> > Cheers, Sergey >> > >> > On 24/07/12 02:45, Willem Jiang wrote: >> >> On Tue, Jul 24, 2012 at 6:16 AM, Sergey >> >> Beryozkin<[hidden email]<http://user/SendEmail.jtp?type=node&node=5716473&i=0>>wrote: >> >> >> >> >>> Hi >> >>> >> >>> On 23/07/12 17:38, dumi_p wrote: >> >>> >> >>>> Hi all, >> >>>> >> >>>> I am using Camel 2.10.0 deployed on Tomcat 7 and I try to test >> >>>> following >> >>>> scenario: >> >>>> >> >>>> 1. Have a CXF rest service deployed >> >>>> 2. Have a proxy CXF rest service over the service above, deployed >> under >> >>>> the >> >>>> same Camel instance >> >>>> >> >>>> It works fine, until I perform requests in parallel. Exception >> >>>> stacktrace >> >>>> is >> >>>> attached. >> >>>> http://camel.465427.n5.nabble.**com/file/n5716351/stacktrace.* >> >>>> *txt<http://camel.465427.n5.nabble.com/file/n5716351/stacktrace.txt> >> >>>> stacktrace.txt >> >>>> >> >>>> I tried following things in class >> >>>> org.apache.camel.component.**cxf.jaxrs.CxfRsProducer order to fix it: >> >>>> 1. Invoked JAXRSClientFactoryBean.**setThreadSafe(true), with no >> >>>> success >> >>>> 2. Added synchronization point over line WebClient client = >> >>>> cfb.createWebClient(), from invokeHttpClient method. It works, but >> >>>> performance dropped on my localhost from 150 requests per second to >> 10 >> >>>> requests per second, so the fix is not acceptable. >> >>>> >> >>>> I attach my camel-config.xml - please let me know if additional info >> is >> >>>> needed. http://camel.465427.n5.nabble.**com/file/n5716351/camel-** >> >>>> config.xml< >> http://camel.465427.n5.nabble.com/file/n5716351/camel-config.xml> >> >>>> >> >>>> camel-config.xml >> >>>> >> >>>> I am not sure if the problem lies in the configuration I performed >> >>>> or in >> >>>> the >> >>>> cxf-rs component or in cxf itself. >> >>>> >> >>>> Any idea is appreciated. >> >>>> >> >>>> Well,I look at the code and see some JAXRSClientFactoryBean cache - >> >>> Willem can you comment on this please ? This looks suspicious. >> >>> >> >> >> >> I don't like the JAXRSClientFactoryBean cache either, it is used to >> >> create the WebClient if we change the URI per request. Now I just want >> to >> >> ask if there is a way to override the server address by setting the >> >> context >> >> per request in the WebClient. >> >> >> >> If So , it could easy for use to resolve the issue. >> >> >> >> >> >>> The trace shows that the thread safety is compromised at the point of >> >>> creating web clients. I can work on a patch - though will take me a >> >>> bit of >> >>> time to get to it >> >>> >> >>> Dumitru - any chance you can declare jaxrs:client or WebClient [1,2] >> >>> explicitly, with a thread safe flag set and reuse it in the routes >> >>> directly >> >>> ? That should do it. >> >>> >> >>> Thanks >> >>> Sergey >> >>> >> >>> [1] >> >>> http://cxf.apache.org/docs/**jax-rs-client-api.html#JAX-**RSClientAPI- >> >>> **ConfiguringHTTPclientsinSpring< >> http://cxf.apache.org/docs/jax-rs-client-api.html#JAX-RSClientAPI-ConfiguringHTTPclientsinSpring> >> >> >>> >> >>> [2] >> >>> http://cxf.apache.org/docs/**jax-rs-client-api.html#JAX-**RSClientAPI- >> >>> **ConfiguringproxiesinSpring< >> http://cxf.apache.org/docs/jax-rs-client-api.html#JAX-RSClientAPI-ConfiguringproxiesinSpring> >> >> >>> >> >>> [2] >> >>> >> >>> >> >>> Best regards, >> >>>> Dumitru >> >>>> >> >>>> >> >>>> >> >>>> -- >> >>>> View this message in context: http://camel.465427.n5.nabble.** >> >>>> com/CxfRsProducer-is-not-**thread-safe-tp5716351.html< >> http://camel.465427.n5.nabble.com/CxfRsProducer-is-not-thread-safe-tp5716351.html> >> >> >>>> >> >>>> Sent from the Camel - Users mailing list archive at Nabble.com. >> >>>> >> >>> >> >>> >> >> >> >> >> >> ------------------------------ >> If you reply to this email, your message will be added to the discussion >> below: >> >> >> . >> NAML<http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml> >> > > > > > -- > View this message in context: http://camel.465427.n5.nabble.com/CxfRsProducer-is-not-thread-safe-tp5716351p5716475.html > Sent from the Camel - Users mailing list archive at Nabble.com. |
|
|
Hi,
I created the JIRA[1]. CamelRoute sample below: /Dumitru // Camel CXF Rest from("cxfrs:bean:rsServer")
.to("log:input") .to("cxfrs:bean:rsClient") .to("log:output")
.process(new Processor() { @Override public void process(Exchange exchange) throws Exception {
log.info("Exchange output: {}", exchange); if (exchange.getIn().getBody() instanceof Customer) {
Customer customer = exchange.getIn().getBody( Customer.class);
Map headers = exchange.getIn().getHeaders(); String name = customer.getName();
customer.setName(name + "123"); exchange.getOut().setBody(customer);
exchange.getOut().setHeaders(headers); } }
}); [1] https://issues.apache.org/jira/browse/CAMEL-5469
On Thu, Jul 26, 2012 at 5:43 AM, Willem.Jiang [via Camel] <[hidden email]> wrote: Dumitru do you mind to create a JIRA[1] here. |
|
|
In reply to this post by Willem.Jiang
Hi,
In the mean time, I tried to use jaxrs:client, but got into another problem. Seems like <jaxrs:client> accepts only interfaces for the serviceClass attribute, so I created a new interface (CustomerServiceInterface) and configured it as it follows:
<jaxrs:client id="rsClient"
serviceClass="org.apache.camel.example.cxf.restobjects.CustomerServiceInterface" inheritHeaders="true">
<jaxrs:headers> <entry key="Accept" value="text/xml" />
</jaxrs:headers> </jaxrs:client> Route is:
from("cxfrs:bean:rsServer") .to("log:input") .to("bean:rsClient")
.to("log:output"); Error I get is: 2012-08-02 23:31:20,894 [http-8080-1 ] ERROR DefaultErrorHandler - Failed delivery for (MessageId: ID-Dumi-PC-57364-1343939398047-0-1 on ExchangeId: ID-Dumi-PC-57364-1343939398047-0-2). Exhausted after delivery attempt: 1 caught: org.apache.camel.component.bean.AmbiguousMethodCallException: Ambiguous method invocations possible: [public final org.apache.camel.example.cxf.restobjects.Customer $Proxy49.getCustomer(java.lang.String), public final org.apache.camel.example.cxf.restobjects.Customer $Proxy49.getCustomer(java.lang.String)]. Exchange[Message: 123]
org.apache.camel.component.bean.AmbiguousMethodCallException: Ambiguous method invocations possible: [public final org.apache.camel.example.cxf.restobjects.Customer $Proxy49.getCustomer(java.lang.String), public final org.apache.camel.example.cxf.restobjects.Customer $Proxy49.getCustomer(java.lang.String)]. Exchange[Message: 123]
at org.apache.camel.component.bean.BeanInfo.chooseBestPossibleMethodInfo(BeanInfo.java:587)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.component.bean.BeanInfo.chooseMethodWithMatchingBody(BeanInfo.java:544)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.component.bean.BeanInfo.chooseMethod(BeanInfo.java:496)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.component.bean.BeanInfo.createInvocation(BeanInfo.java:225)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.component.bean.BeanInfo.createInvocation(BeanInfo.java:162)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java:149)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:99)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java:73)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.impl.ProcessorEndpoint.onExchange(ProcessorEndpoint.java:101)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.impl.ProcessorEndpoint$1.process(ProcessorEndpoint.java:71)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:120)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:292)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:115)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:91)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:330)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:220)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:303)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.processor.Pipeline.process(Pipeline.java:117)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.processor.Pipeline.process(Pipeline.java:80)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.processor.UnitOfWorkProcessor.processAsync(UnitOfWorkProcessor.java:150)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:117)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.processor.RouteInflightRepositoryProcessor.processNext(RouteInflightRepositoryProcessor.java:48)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:99)[camel-core-2.10.0.jar:2.10.0]
at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:86)[camel-core-2.10.0.jar:2.10.0] at org.apache.camel.component.cxf.jaxrs.CxfRsInvoker.syncInvoke(CxfRsInvoker.java:122)[camel-cxf-2.10.0.jar:2.10.0]
at org.apache.camel.component.cxf.jaxrs.CxfRsInvoker.performInvocation(CxfRsInvoker.java:60)[camel-cxf-2.10.0.jar:2.10.0] at org.apache.cxf.service.invoker.AbstractInvoker.invoke(AbstractInvoker.java:96)[cxf-api-2.6.1.jar:2.6.1]
at org.apache.cxf.jaxrs.JAXRSInvoker.invoke(JAXRSInvoker.java:167)[cxf-rt-frontend-jaxrs-2.6.1.jar:2.6.1] at org.apache.cxf.jaxrs.JAXRSInvoker.invoke(JAXRSInvoker.java:94)[cxf-rt-frontend-jaxrs-2.6.1.jar:2.6.1]
at org.apache.cxf.interceptor.ServiceInvokerInterceptor$1.run(ServiceInvokerInterceptor.java:58)[cxf-api-2.6.1.jar:2.6.1] at org.apache.cxf.interceptor.ServiceInvokerInterceptor.handleMessage(ServiceInvokerInterceptor.java:94)[cxf-api-2.6.1.jar:2.6.1]
at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:262)[cxf-api-2.6.1.jar:2.6.1] at org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInitiationObserver.java:122)[cxf-api-2.6.1.jar:2.6.1]
at org.apache.cxf.transport.http.AbstractHTTPDestination.invoke(AbstractHTTPDestination.java:211)[cxf-rt-transports-http-2.6.1.jar:2.6.1] at org.apache.cxf.transport.servlet.ServletController.invokeDestination(ServletController.java:213)[cxf-rt-transports-http-2.6.1.jar:2.6.1]
at org.apache.cxf.transport.servlet.ServletController.invoke(ServletController.java:154)[cxf-rt-transports-http-2.6.1.jar:2.6.1] at org.apache.cxf.transport.servlet.CXFNonSpringServlet.invoke(CXFNonSpringServlet.java:129)[cxf-rt-transports-http-2.6.1.jar:2.6.1]
at org.apache.cxf.transport.servlet.AbstractHTTPServlet.handleRequest(AbstractHTTPServlet.java:187)[cxf-rt-transports-http-2.6.1.jar:2.6.1] at org.apache.cxf.transport.servlet.AbstractHTTPServlet.doGet(AbstractHTTPServlet.java:115)[cxf-rt-transports-http-2.6.1.jar:2.6.1]
at javax.servlet.http.HttpServlet.service(HttpServlet.java:617)[servlet-api-6.0.29.jar:] at org.apache.cxf.transport.servlet.AbstractHTTPServlet.service(AbstractHTTPServlet.java:166)[cxf-rt-transports-http-2.6.1.jar:2.6.1]
at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:290)[catalina-6.0.29.jar:6.0.29] at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206)[catalina-6.0.29.jar:6.0.29]
at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:233)[catalina-6.0.29.jar:6.0.29] at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:191)[catalina-6.0.29.jar:6.0.29]
at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:127)[catalina-6.0.29.jar:6.0.29] at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:102)[catalina-6.0.29.jar:6.0.29]
at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:109)[catalina-6.0.29.jar:6.0.29] at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:298)[catalina-6.0.29.jar:6.0.29]
at org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:857)[coyote-6.0.29.jar:6.0.29] at org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.process(Http11Protocol.java:588)[coyote-6.0.29.jar:6.0.29]
at org.apache.tomcat.util.net.JIoEndpoint$Worker.run(JIoEndpoint.java:489)[coyote-6.0.29.jar:6.0.29] Attached relevant files.
Any help appreciated. Regards, /Dumitru  CustomerService.java (5K) Download Attachment CustomerServiceInterface.java (2K) Download Attachment camel-config.xml (4K) Download Attachment CamelRoute.java (2K) Download Attachment |
Re: CxfRsProducer is not thread safe
|
|
Hi
On 02/08/12 23:42, dumi_p wrote: > Hi, > > In the mean time, I tried to use jaxrs:client, but got into another > problem. Seems like<jaxrs:client> accepts only interfaces for the > serviceClass attribute, so I created a new interface it can create proxies from concrete classes, but it needs a cglib-nodep for it to work. > (CustomerServiceInterface) and configured it as it follows: > <jaxrs:client id="rsClient" > address="http://localhost:8080/camel-example-cxf-tomcat/webservices/rest" > serviceClass="org.apache.camel.example.cxf.restobjects.CustomerServiceInterface" > inheritHeaders="true"> > <jaxrs:headers> > <entry key="Accept" value="text/xml" /> > </jaxrs:headers> > </jaxrs:client> > add a 'threadSafe' flag please > Route is: > from("cxfrs:bean:rsServer") > .to("log:input") > .to("bean:rsClient") > .to("log:output"); > > Error I get is: I think the exception below suggests a camel bean component can not invoke on proxies. Cheers, Sergey P.S. Btw, if you can get a chance, please try a test code I attached to JIRA. I do not dispute the fact you saw the thread-safety related exception but I need to create a failing test to start with :-) and the test I did mimics the way your route works very closely > 2012-08-02 23:31:20,894 [http-8080-1 ] ERROR DefaultErrorHandler > - Failed delivery for (MessageId: ID-Dumi-PC-57364-1343939398047-0-1 on > ExchangeId: ID-Dumi-PC-57364-1343939398047-0-2). Exhausted after delivery > attempt: 1 caught: > org.apache.camel.component.bean.AmbiguousMethodCallException: Ambiguous > method invocations possible: [public final > org.apache.camel.example.cxf.restobjects.Customer > $Proxy49.getCustomer(java.lang.String), public final > org.apache.camel.example.cxf.restobjects.Customer > $Proxy49.getCustomer(java.lang.String)]. Exchange[Message: 123] > org.apache.camel.component.bean.AmbiguousMethodCallException: Ambiguous > method invocations possible: [public final > org.apache.camel.example.cxf.restobjects.Customer > $Proxy49.getCustomer(java.lang.String), public final > org.apache.camel.example.cxf.restobjects.Customer > $Proxy49.getCustomer(java.lang.String)]. Exchange[Message: 123] > at > org.apache.camel.component.bean.BeanInfo.chooseBestPossibleMethodInfo(BeanInfo.java:587)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.component.bean.BeanInfo.chooseMethodWithMatchingBody(BeanInfo.java:544)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.component.bean.BeanInfo.chooseMethod(BeanInfo.java:496)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.component.bean.BeanInfo.createInvocation(BeanInfo.java:225)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.component.bean.BeanInfo.createInvocation(BeanInfo.java:162)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java:149)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:99)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java:73)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.impl.ProcessorEndpoint.onExchange(ProcessorEndpoint.java:101)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.impl.ProcessorEndpoint$1.process(ProcessorEndpoint.java:71)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:120)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:292)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.SendProcessor.process(SendProcessor.java:115)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:91)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:330)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:220)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:303)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.Pipeline.process(Pipeline.java:117)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.Pipeline.process(Pipeline.java:80)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.UnitOfWorkProcessor.processAsync(UnitOfWorkProcessor.java:150)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:117)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.RouteInflightRepositoryProcessor.processNext(RouteInflightRepositoryProcessor.java:48)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:99)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:86)[camel-core-2.10.0.jar:2.10.0] > at > org.apache.camel.component.cxf.jaxrs.CxfRsInvoker.syncInvoke(CxfRsInvoker.java:122)[camel-cxf-2.10.0.jar:2.10.0] > at > org.apache.camel.component.cxf.jaxrs.CxfRsInvoker.performInvocation(CxfRsInvoker.java:60)[camel-cxf-2.10.0.jar:2.10.0] > at > org.apache.cxf.service.invoker.AbstractInvoker.invoke(AbstractInvoker.java:96)[cxf-api-2.6.1.jar:2.6.1] > at > org.apache.cxf.jaxrs.JAXRSInvoker.invoke(JAXRSInvoker.java:167)[cxf-rt-frontend-jaxrs-2.6.1.jar:2.6.1] > at > org.apache.cxf.jaxrs.JAXRSInvoker.invoke(JAXRSInvoker.java:94)[cxf-rt-frontend-jaxrs-2.6.1.jar:2.6.1] > at > org.apache.cxf.interceptor.ServiceInvokerInterceptor$1.run(ServiceInvokerInterceptor.java:58)[cxf-api-2.6.1.jar:2.6.1] > at > org.apache.cxf.interceptor.ServiceInvokerInterceptor.handleMessage(ServiceInvokerInterceptor.java:94)[cxf-api-2.6.1.jar:2.6.1] > at > org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:262)[cxf-api-2.6.1.jar:2.6.1] > at > org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInitiationObserver.java:122)[cxf-api-2.6.1.jar:2.6.1] > at > org.apache.cxf.transport.http.AbstractHTTPDestination.invoke(AbstractHTTPDestination.java:211)[cxf-rt-transports-http-2.6.1.jar:2.6.1] > at > org.apache.cxf.transport.servlet.ServletController.invokeDestination(ServletController.java:213)[cxf-rt-transports-http-2.6.1.jar:2.6.1] > at > org.apache.cxf.transport.servlet.ServletController.invoke(ServletController.java:154)[cxf-rt-transports-http-2.6.1.jar:2.6.1] > at > org.apache.cxf.transport.servlet.CXFNonSpringServlet.invoke(CXFNonSpringServlet.java:129)[cxf-rt-transports-http-2.6.1.jar:2.6.1] > at > org.apache.cxf.transport.servlet.AbstractHTTPServlet.handleRequest(AbstractHTTPServlet.java:187)[cxf-rt-transports-http-2.6.1.jar:2.6.1] > at > org.apache.cxf.transport.servlet.AbstractHTTPServlet.doGet(AbstractHTTPServlet.java:115)[cxf-rt-transports-http-2.6.1.jar:2.6.1] > at > javax.servlet.http.HttpServlet.service(HttpServlet.java:617)[servlet-api-6.0.29.jar:] > at > org.apache.cxf.transport.servlet.AbstractHTTPServlet.service(AbstractHTTPServlet.java:166)[cxf-rt-transports-http-2.6.1.jar:2.6.1] > at > org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:290)[catalina-6.0.29.jar:6.0.29] > at > org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206)[catalina-6.0.29.jar:6.0.29] > at > org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:233)[catalina-6.0.29.jar:6.0.29] > at > org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:191)[catalina-6.0.29.jar:6.0.29] > at > org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:127)[catalina-6.0.29.jar:6.0.29] > at > org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:102)[catalina-6.0.29.jar:6.0.29] > at > org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:109)[catalina-6.0.29.jar:6.0.29] > at > org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:298)[catalina-6.0.29.jar:6.0.29] > at > org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:857)[coyote-6.0.29.jar:6.0.29] > at > org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.process(Http11Protocol.java:588)[coyote-6.0.29.jar:6.0.29] > at > org.apache.tomcat.util.net.JIoEndpoint$Worker.run(JIoEndpoint.java:489)[coyote-6.0.29.jar:6.0.29] > > Attached relevant files. > > Any help appreciated. > > Regards, > /Dumitru > > > > > -- > View this message in context: http://camel.465427.n5.nabble.com/CxfRsProducer-is-not-thread-safe-tp5716351p5716712.html > Sent from the Camel - Users mailing list archive at Nabble.com. |
Re: CxfRsProducer is not thread safe
|
|
On 03/08/12 10:26, Sergey Beryozkin wrote:
> Hi > On 02/08/12 23:42, dumi_p wrote: >> Hi, >> >> In the mean time, I tried to use jaxrs:client, but got into another >> problem. Seems like<jaxrs:client> accepts only interfaces for the >> serviceClass attribute, so I created a new interface > > it can create proxies from concrete classes, but it needs a cglib-nodep > for it to work. > >> (CustomerServiceInterface) and configured it as it follows: >> <jaxrs:client id="rsClient" >> address="http://localhost:8080/camel-example-cxf-tomcat/webservices/rest" >> serviceClass="org.apache.camel.example.cxf.restobjects.CustomerServiceInterface" >> >> inheritHeaders="true"> >> <jaxrs:headers> >> <entry key="Accept" value="text/xml" /> >> </jaxrs:headers> >> </jaxrs:client> >> > > add a 'threadSafe' flag please > >> Route is: >> from("cxfrs:bean:rsServer") >> .to("log:input") >> .to("bean:rsClient") >> .to("log:output"); >> >> Error I get is: > > I think the exception below suggests a camel bean component can not > invoke on proxies. > Actually, it seems more to do with the misconfiguration, according to http://camel.apache.org/bean.html one needs to specify a 'method' parameter Try it please Sergey > Cheers, Sergey > > P.S. Btw, if you can get a chance, please try a test code I attached to > JIRA. I do not dispute the fact you saw the thread-safety related > exception but I need to create a failing test to start with :-) and the > test I did mimics the way your route works very closely > >> 2012-08-02 23:31:20,894 [http-8080-1 ] ERROR DefaultErrorHandler >> - Failed delivery for (MessageId: ID-Dumi-PC-57364-1343939398047-0-1 on >> ExchangeId: ID-Dumi-PC-57364-1343939398047-0-2). Exhausted after delivery >> attempt: 1 caught: >> org.apache.camel.component.bean.AmbiguousMethodCallException: Ambiguous >> method invocations possible: [public final >> org.apache.camel.example.cxf.restobjects.Customer >> $Proxy49.getCustomer(java.lang.String), public final >> org.apache.camel.example.cxf.restobjects.Customer >> $Proxy49.getCustomer(java.lang.String)]. Exchange[Message: 123] >> org.apache.camel.component.bean.AmbiguousMethodCallException: Ambiguous >> method invocations possible: [public final >> org.apache.camel.example.cxf.restobjects.Customer >> $Proxy49.getCustomer(java.lang.String), public final >> org.apache.camel.example.cxf.restobjects.Customer >> $Proxy49.getCustomer(java.lang.String)]. Exchange[Message: 123] >> at >> org.apache.camel.component.bean.BeanInfo.chooseBestPossibleMethodInfo(BeanInfo.java:587)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.component.bean.BeanInfo.chooseMethodWithMatchingBody(BeanInfo.java:544)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.component.bean.BeanInfo.chooseMethod(BeanInfo.java:496)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.component.bean.BeanInfo.createInvocation(BeanInfo.java:225)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.component.bean.BeanInfo.createInvocation(BeanInfo.java:162)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java:149)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:99)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java:73)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.impl.ProcessorEndpoint.onExchange(ProcessorEndpoint.java:101)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.impl.ProcessorEndpoint$1.process(ProcessorEndpoint.java:71)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:120)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:292)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:115)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:91)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:330)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:220)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:303)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.Pipeline.process(Pipeline.java:117)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.Pipeline.process(Pipeline.java:80)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.UnitOfWorkProcessor.processAsync(UnitOfWorkProcessor.java:150)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:117)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.RouteInflightRepositoryProcessor.processNext(RouteInflightRepositoryProcessor.java:48)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:99)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:86)[camel-core-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.component.cxf.jaxrs.CxfRsInvoker.syncInvoke(CxfRsInvoker.java:122)[camel-cxf-2.10.0.jar:2.10.0] >> >> at >> org.apache.camel.component.cxf.jaxrs.CxfRsInvoker.performInvocation(CxfRsInvoker.java:60)[camel-cxf-2.10.0.jar:2.10.0] >> >> at >> org.apache.cxf.service.invoker.AbstractInvoker.invoke(AbstractInvoker.java:96)[cxf-api-2.6.1.jar:2.6.1] >> >> at >> org.apache.cxf.jaxrs.JAXRSInvoker.invoke(JAXRSInvoker.java:167)[cxf-rt-frontend-jaxrs-2.6.1.jar:2.6.1] >> >> at >> org.apache.cxf.jaxrs.JAXRSInvoker.invoke(JAXRSInvoker.java:94)[cxf-rt-frontend-jaxrs-2.6.1.jar:2.6.1] >> >> at >> org.apache.cxf.interceptor.ServiceInvokerInterceptor$1.run(ServiceInvokerInterceptor.java:58)[cxf-api-2.6.1.jar:2.6.1] >> >> at >> org.apache.cxf.interceptor.ServiceInvokerInterceptor.handleMessage(ServiceInvokerInterceptor.java:94)[cxf-api-2.6.1.jar:2.6.1] >> >> at >> org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:262)[cxf-api-2.6.1.jar:2.6.1] >> >> at >> org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInitiationObserver.java:122)[cxf-api-2.6.1.jar:2.6.1] >> >> at >> org.apache.cxf.transport.http.AbstractHTTPDestination.invoke(AbstractHTTPDestination.java:211)[cxf-rt-transports-http-2.6.1.jar:2.6.1] >> >> at >> org.apache.cxf.transport.servlet.ServletController.invokeDestination(ServletController.java:213)[cxf-rt-transports-http-2.6.1.jar:2.6.1] >> >> at >> org.apache.cxf.transport.servlet.ServletController.invoke(ServletController.java:154)[cxf-rt-transports-http-2.6.1.jar:2.6.1] >> >> at >> org.apache.cxf.transport.servlet.CXFNonSpringServlet.invoke(CXFNonSpringServlet.java:129)[cxf-rt-transports-http-2.6.1.jar:2.6.1] >> >> at >> org.apache.cxf.transport.servlet.AbstractHTTPServlet.handleRequest(AbstractHTTPServlet.java:187)[cxf-rt-transports-http-2.6.1.jar:2.6.1] >> >> at >> org.apache.cxf.transport.servlet.AbstractHTTPServlet.doGet(AbstractHTTPServlet.java:115)[cxf-rt-transports-http-2.6.1.jar:2.6.1] >> >> at >> javax.servlet.http.HttpServlet.service(HttpServlet.java:617)[servlet-api-6.0.29.jar:] >> >> at >> org.apache.cxf.transport.servlet.AbstractHTTPServlet.service(AbstractHTTPServlet.java:166)[cxf-rt-transports-http-2.6.1.jar:2.6.1] >> >> at >> org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:290)[catalina-6.0.29.jar:6.0.29] >> >> at >> org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206)[catalina-6.0.29.jar:6.0.29] >> >> at >> org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:233)[catalina-6.0.29.jar:6.0.29] >> >> at >> org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:191)[catalina-6.0.29.jar:6.0.29] >> >> at >> org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:127)[catalina-6.0.29.jar:6.0.29] >> >> at >> org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:102)[catalina-6.0.29.jar:6.0.29] >> >> at >> org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:109)[catalina-6.0.29.jar:6.0.29] >> >> at >> org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:298)[catalina-6.0.29.jar:6.0.29] >> >> at >> org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:857)[coyote-6.0.29.jar:6.0.29] >> >> at >> org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.process(Http11Protocol.java:588)[coyote-6.0.29.jar:6.0.29] >> >> at >> org.apache.tomcat.util.net.JIoEndpoint$Worker.run(JIoEndpoint.java:489)[coyote-6.0.29.jar:6.0.29] >> >> >> Attached relevant files. >> >> Any help appreciated. >> >> Regards, >> /Dumitru >> >> >> >> >> -- >> View this message in context: >> http://camel.465427.n5.nabble.com/CxfRsProducer-is-not-thread-safe-tp5716351p5716712.html >> >> Sent from the Camel - Users mailing list archive at Nabble.com. > |
|
|
Thank you, that did it: added cglib and operation name for the bean route.
Although for the moment it works, I don't necessarily like adding the method name in the route, as I would have preferred to have the proxy more generic - for all methods exposed by the webservice in the backend.
I ran the test you've send me and surprisingly it does not fail although it seems almost identical to my case. I will look more into it tomorrow. Best regards, /Dumitru
On Fri, Aug 3, 2012 at 10:42 AM, Sergey Beryozkin-3 [via Camel] <[hidden email]> wrote:
|
Re: CxfRsProducer is not thread safe
|
|
HI Dumitru
On 05/08/12 00:44, dumi_p wrote: > Thank you, that did it: added cglib and operation name for the bean route. OK, thanks for the confirmation. I think I need to get a permission to update the Camel wiki and add some additional info on how CXF JAX-RS code can work with core Camel components (bean comp, camel transport) > > Although for the moment it works, I don't necessarily like adding the > method name in the route, as I would have preferred to have the proxy more > generic - for all methods exposed by the webservice in the backend. > Sure; you may also want to try to instantiate a CXF WebClient as a bean, in which case it can be a bit simpler to offer a generic route, with only the webclient path changing, etc > I ran the test you've send me and surprisingly it does not fail although it > seems almost identical to my case. I will look more into it tomorrow. > Thanks; Cheers, Sergey > Best regards, > /Dumitru > > On Fri, Aug 3, 2012 at 10:42 AM, Sergey Beryozkin-3 [via Camel]< > [hidden email]> wrote: > >> On 03/08/12 10:26, Sergey Beryozkin wrote: >> >>> Hi >>> On 02/08/12 23:42, dumi_p wrote: >>>> Hi, >>>> >>>> In the mean time, I tried to use jaxrs:client, but got into another >>>> problem. Seems like<jaxrs:client> accepts only interfaces for the >>>> serviceClass attribute, so I created a new interface >>> >>> it can create proxies from concrete classes, but it needs a cglib-nodep >>> for it to work. >>> >>>> (CustomerServiceInterface) and configured it as it follows: >>>> <jaxrs:client id="rsClient" >>>> address=" >> http://localhost:8080/camel-example-cxf-tomcat/webservices/rest" >>>> >> serviceClass="org.apache.camel.example.cxf.restobjects.CustomerServiceInterface" >> >>>> >>>> inheritHeaders="true"> >>>> <jaxrs:headers> >>>> <entry key="Accept" value="text/xml" /> >>>> </jaxrs:headers> >>>> </jaxrs:client> >>>> >>> >>> add a 'threadSafe' flag please >>> >>>> Route is: >>>> from("cxfrs:bean:rsServer") >>>> .to("log:input") >>>> .to("bean:rsClient") >>>> .to("log:output"); >>>> >>>> Error I get is: >>> >>> I think the exception below suggests a camel bean component can not >>> invoke on proxies. >>> >> >> Actually, it seems more to do with the misconfiguration, according to >> http://camel.apache.org/bean.html >> >> one needs to specify a 'method' parameter >> >> Try it please >> Sergey >> >>> Cheers, Sergey >>> >>> P.S. Btw, if you can get a chance, please try a test code I attached to >>> JIRA. I do not dispute the fact you saw the thread-safety related >>> exception but I need to create a failing test to start with :-) and the >>> test I did mimics the way your route works very closely >>> >>>> 2012-08-02 23:31:20,894 [http-8080-1 ] ERROR DefaultErrorHandler >>>> - Failed delivery for (MessageId: ID-Dumi-PC-57364-1343939398047-0-1 on >>>> ExchangeId: ID-Dumi-PC-57364-1343939398047-0-2). Exhausted after >> delivery >>>> attempt: 1 caught: >>>> org.apache.camel.component.bean.AmbiguousMethodCallException: Ambiguous >>>> method invocations possible: [public final >>>> org.apache.camel.example.cxf.restobjects.Customer >>>> $Proxy49.getCustomer(java.lang.String), public final >>>> org.apache.camel.example.cxf.restobjects.Customer >>>> $Proxy49.getCustomer(java.lang.String)]. Exchange[Message: 123] >>>> org.apache.camel.component.bean.AmbiguousMethodCallException: Ambiguous >>>> method invocations possible: [public final >>>> org.apache.camel.example.cxf.restobjects.Customer >>>> $Proxy49.getCustomer(java.lang.String), public final >>>> org.apache.camel.example.cxf.restobjects.Customer >>>> $Proxy49.getCustomer(java.lang.String)]. Exchange[Message: 123] >>>> at >>>> >> org.apache.camel.component.bean.BeanInfo.chooseBestPossibleMethodInfo(BeanInfo.java:587)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.component.bean.BeanInfo.chooseMethodWithMatchingBody(BeanInfo.java:544)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.component.bean.BeanInfo.chooseMethod(BeanInfo.java:496)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.component.bean.BeanInfo.createInvocation(BeanInfo.java:225)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.component.bean.BeanInfo.createInvocation(BeanInfo.java:162)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java:149)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:99)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.component.bean.BeanProcessor.process(BeanProcessor.java:73)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.impl.ProcessorEndpoint.onExchange(ProcessorEndpoint.java:101)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.impl.ProcessorEndpoint$1.process(ProcessorEndpoint.java:71)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.SendProcessor$2.doInAsyncProducer(SendProcessor.java:120)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.impl.ProducerCache.doInAsyncProducer(ProducerCache.java:292)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:115)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:91)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:330)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:220)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.interceptor.DefaultChannel.process(DefaultChannel.java:303)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.Pipeline.process(Pipeline.java:117)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.Pipeline.process(Pipeline.java:80)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.RouteContextProcessor.processNext(RouteContextProcessor.java:45)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.UnitOfWorkProcessor.processAsync(UnitOfWorkProcessor.java:150)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:117)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.RouteInflightRepositoryProcessor.processNext(RouteInflightRepositoryProcessor.java:48)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:73)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:99)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:90)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:73)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:99)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:86)[camel-core-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.component.cxf.jaxrs.CxfRsInvoker.syncInvoke(CxfRsInvoker.java:122)[camel-cxf-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.camel.component.cxf.jaxrs.CxfRsInvoker.performInvocation(CxfRsInvoker.java:60)[camel-cxf-2.10.0.jar:2.10.0] >> >>>> >>>> at >>>> >> org.apache.cxf.service.invoker.AbstractInvoker.invoke(AbstractInvoker.java:96)[cxf-api-2.6.1.jar:2.6.1] >> >>>> >>>> at >>>> >> org.apache.cxf.jaxrs.JAXRSInvoker.invoke(JAXRSInvoker.java:167)[cxf-rt-frontend-jaxrs-2.6.1.jar:2.6.1] >> >>>> >>>> at >>>> >> org.apache.cxf.jaxrs.JAXRSInvoker.invoke(JAXRSInvoker.java:94)[cxf-rt-frontend-jaxrs-2.6.1.jar:2.6.1] >> >>>> >>>> at >>>> >> org.apache.cxf.interceptor.ServiceInvokerInterceptor$1.run(ServiceInvokerInterceptor.java:58)[cxf-api-2.6.1.jar:2.6.1] >> >>>> >>>> at >>>> >> org.apache.cxf.interceptor.ServiceInvokerInterceptor.handleMessage(ServiceInvokerInterceptor.java:94)[cxf-api-2.6.1.jar:2.6.1] >> >>>> >>>> at >>>> >> org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:262)[cxf-api-2.6.1.jar:2.6.1] >> >>>> >>>> at >>>> >> org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInitiationObserver.java:122)[cxf-api-2.6.1.jar:2.6.1] >> >>>> >>>> at >>>> >> org.apache.cxf.transport.http.AbstractHTTPDestination.invoke(AbstractHTTPDestination.java:211)[cxf-rt-transports-http-2.6.1.jar:2.6.1] >> >>>> >>>> at >>>> >> org.apache.cxf.transport.servlet.ServletController.invokeDestination(ServletController.java:213)[cxf-rt-transports-http-2.6.1.jar:2.6.1] >> >>>> >>>> at >>>> >> org.apache.cxf.transport.servlet.ServletController.invoke(ServletController.java:154)[cxf-rt-transports-http-2.6.1.jar:2.6.1] >> >>>> >>>> at >>>> >> org.apache.cxf.transport.servlet.CXFNonSpringServlet.invoke(CXFNonSpringServlet.java:129)[cxf-rt-transports-http-2.6.1.jar:2.6.1] >> >>>> >>>> at >>>> >> org.apache.cxf.transport.servlet.AbstractHTTPServlet.handleRequest(AbstractHTTPServlet.java:187)[cxf-rt-transports-http-2.6.1.jar:2.6.1] >> >>>> >>>> at >>>> >> org.apache.cxf.transport.servlet.AbstractHTTPServlet.doGet(AbstractHTTPServlet.java:115)[cxf-rt-transports-http-2.6.1.jar:2.6.1] >> >>>> >>>> at >>>> >> javax.servlet.http.HttpServlet.service(HttpServlet.java:617)[servlet-api-6.0.29.jar:] >> >>>> >>>> at >>>> >> org.apache.cxf.transport.servlet.AbstractHTTPServlet.service(AbstractHTTPServlet.java:166)[cxf-rt-transports-http-2.6.1.jar:2.6.1] >> >>>> >>>> at >>>> >> org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:290)[catalina-6.0.29.jar:6.0.29] >> >>>> >>>> at >>>> >> org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206)[catalina-6.0.29.jar:6.0.29] >> >>>> >>>> at >>>> >> org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:233)[catalina-6.0.29.jar:6.0.29] >> >>>> >>>> at >>>> >> org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:191)[catalina-6.0.29.jar:6.0.29] >> >>>> >>>> at >>>> >> org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:127)[catalina-6.0.29.jar:6.0.29] >> >>>> >>>> at >>>> >> org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:102)[catalina-6.0.29.jar:6.0.29] >> >>>> >>>> at >>>> >> org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:109)[catalina-6.0.29.jar:6.0.29] >> >>>> >>>> at >>>> >> org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:298)[catalina-6.0.29.jar:6.0.29] >> >>>> >>>> at >>>> >> org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:857)[coyote-6.0.29.jar:6.0.29] >> >>>> >>>> at >>>> >> org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.process(Http11Protocol.java:588)[coyote-6.0.29.jar:6.0.29] >> >>>> >>>> at >>>> >> org.apache.tomcat.util.net.JIoEndpoint$Worker.run(JIoEndpoint.java:489)[coyote-6.0.29.jar:6.0.29] >> >>>> >>>> >>>> Attached relevant files. >>>> >>>> Any help appreciated. >>>> >>>> Regards, >>>> /Dumitru >>>> >>>> >>>> >>>> >>>> -- >>>> View this message in context: >>>> >> http://camel.465427.n5.nabble.com/CxfRsProducer-is-not-thread-safe-tp5716351p5716712.html >>>> >>>> Sent from the Camel - Users mailing list archive at Nabble.com. >>> >> >> >> ------------------------------ >> If you reply to this email, your message will be added to the discussion >> below: >> >> >> . >> NAML<http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml> >> > > > > > -- > View this message in context: http://camel.465427.n5.nabble.com/CxfRsProducer-is-not-thread-safe-tp5716351p5716836.html > Sent from the Camel - Users mailing list archive at Nabble.com. |
|
|
Thank you, Sergey for your help!
I used your unit tests and tried to reproduce the problem, yet without success. Still, one can reproduce the issue using JMeter and the working project I've attached in the jira issue.
Regards, Dumitru
On Sun, Aug 5, 2012 at 6:36 PM, Sergey Beryozkin-3 [via Camel] <[hidden email]> wrote:
|
«
Return to Camel - Users
|
1 view|%1 views
Loading...
| Powered by Nabble | Edit this page |