You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by Achim Nierbeck <bc...@googlemail.com> on 2011/07/29 13:24:32 UTC
CXF Client in a threaded route
Hi,
I'm trying to do the following
<camel:route>
<camel:from uri="seda:input" />
<camel:recipientList>
<camel:simple>cxf:bean:productionServer?address=${header.address}</camel:simple>
</camel:recipientList>
this fails with a
PhaseInterceptorChain WARN Interceptor for
{http://tempuri.org/}Service#{http://my-namespace}Initialize has
thrown exception, unwinding now
org.apache.cxf.interceptor.Fault: Could not send Message.
at org.apache.cxf.interceptor.MessageSenderInterceptor$MessageSenderEndingInterceptor.handleMessage(MessageSenderInterceptor.java:64)[cxf-rt-core-2.4.1.jar:2.4.1]
at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:263)[cxf-api-2.4.1.jar:2.4.1]
at org.apache.cxf.endpoint.ClientImpl.doInvoke(ClientImpl.java:510)[cxf-rt-core-2.4.1.jar:2.4.1]
at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:433)[cxf-rt-core-2.4.1.jar:2.4.1]
at org.apache.camel.component.cxf.CxfProducer.process(CxfProducer.java:94)[camel-cxf-2.8.0.jar:2.8.0]
at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:78)[camel-core-2.8.0.jar:2.8.0]
at org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:318)[camel-core-2.8.0.jar:2.8.0]
at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:209)[camel-core-2.8.0.jar:2.8.0]
at org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:102)[camel-core-2.8.0.jar:2.8.0]
at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:78)[camel-core-2.8.0.jar:2.8.0]
at org.apache.camel.processor.MulticastProcessor.doProcessSequential(MulticastProcessor.java:572)[camel-core-2.8.0.jar:2.8.0]
at org.apache.camel.processor.MulticastProcessor.doProcessSequential(MulticastProcessor.java:505)[camel-core-2.8.0.jar:2.8.0]
at org.apache.camel.processor.MulticastProcessor.process(MulticastProcessor.java:218)[camel-core-2.8.0.jar:2.8.0]
at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:78)[camel-core-2.8.0.jar:2.8.0]
at org.apache.camel.processor.RecipientList.sendToRecipientList(RecipientList.java:144)[camel-core-2.8.0.jar:2.8.0]
at org.apache.camel.processor.RecipientList.process(RecipientList.java:105)[camel-core-2.8.0.jar:2.8.0]
at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:78)[camel-core-2.8.0.jar:2.8.0]
at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[camel-core-2.8.0.jar:2.8.0]
......
if I change the starting endpoint to
<camel:from uri="direct:input" />
it works without any issues.
so what am I doing wrong here?
Regards
--
*Achim Nierbeck*
Apache Karaf <http://karaf.apache.org/> Committer & PMC
OPS4J Pax Web <http://wiki.ops4j.org/display/paxweb/Pax+Web/>
Committer & Project Lead
blog <http://notizblog.nierbeck.de/>
Re: CXF Client in a threaded route
Posted by Achim Nierbeck <bc...@googlemail.com>.
FYI, no problem anymore just didn't see the needed config param
camel:recipientList needs to be configured to run threaded
<camel:recipientList parallelProcessing="true" >
<camel:simple>cxf:bean:productionServer?address=${header.address}</camel:simple>
</camel:recipientList>
fixed it.
thanx anyways, Achim :-)
2011/7/29 Achim Nierbeck <bc...@googlemail.com>:
> Hi,
>
> I'm trying to do the following
>
> <camel:route>
> <camel:from uri="seda:input" />
> <camel:recipientList>
> <camel:simple>cxf:bean:productionServer?address=${header.address}</camel:simple>
> </camel:recipientList>
>
> this fails with a
>
> PhaseInterceptorChain WARN Interceptor for
> {http://tempuri.org/}Service#{http://my-namespace}Initialize has
> thrown exception, unwinding now
> org.apache.cxf.interceptor.Fault: Could not send Message.
> at org.apache.cxf.interceptor.MessageSenderInterceptor$MessageSenderEndingInterceptor.handleMessage(MessageSenderInterceptor.java:64)[cxf-rt-core-2.4.1.jar:2.4.1]
> at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:263)[cxf-api-2.4.1.jar:2.4.1]
> at org.apache.cxf.endpoint.ClientImpl.doInvoke(ClientImpl.java:510)[cxf-rt-core-2.4.1.jar:2.4.1]
> at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:433)[cxf-rt-core-2.4.1.jar:2.4.1]
> at org.apache.camel.component.cxf.CxfProducer.process(CxfProducer.java:94)[camel-cxf-2.8.0.jar:2.8.0]
> at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:78)[camel-core-2.8.0.jar:2.8.0]
> at org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:318)[camel-core-2.8.0.jar:2.8.0]
> at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:209)[camel-core-2.8.0.jar:2.8.0]
> at org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:102)[camel-core-2.8.0.jar:2.8.0]
> at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:78)[camel-core-2.8.0.jar:2.8.0]
> at org.apache.camel.processor.MulticastProcessor.doProcessSequential(MulticastProcessor.java:572)[camel-core-2.8.0.jar:2.8.0]
> at org.apache.camel.processor.MulticastProcessor.doProcessSequential(MulticastProcessor.java:505)[camel-core-2.8.0.jar:2.8.0]
> at org.apache.camel.processor.MulticastProcessor.process(MulticastProcessor.java:218)[camel-core-2.8.0.jar:2.8.0]
> at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:78)[camel-core-2.8.0.jar:2.8.0]
> at org.apache.camel.processor.RecipientList.sendToRecipientList(RecipientList.java:144)[camel-core-2.8.0.jar:2.8.0]
> at org.apache.camel.processor.RecipientList.process(RecipientList.java:105)[camel-core-2.8.0.jar:2.8.0]
> at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:78)[camel-core-2.8.0.jar:2.8.0]
> at org.apache.camel.processor.DelegateAsyncProcessor.processNext(DelegateAsyncProcessor.java:98)[camel-core-2.8.0.jar:2.8.0]
> ......
>
> if I change the starting endpoint to
> <camel:from uri="direct:input" />
>
> it works without any issues.
>
> so what am I doing wrong here?
>
> Regards
>
> --
> *Achim Nierbeck*
>
>
> Apache Karaf <http://karaf.apache.org/> Committer & PMC
> OPS4J Pax Web <http://wiki.ops4j.org/display/paxweb/Pax+Web/>
> Committer & Project Lead
> blog <http://notizblog.nierbeck.de/>
>
--
--
*Achim Nierbeck*
Apache Karaf <http://karaf.apache.org/> Committer & PMC
OPS4J Pax Web <http://wiki.ops4j.org/display/paxweb/Pax+Web/>
Committer & Project Lead
blog <http://notizblog.nierbeck.de/>