Return-Path: 
 <users-return-6184-apmail-camel-users-archive=camel.apache.org@camel.apache.org>
Delivered-To: apmail-camel-users-archive@www.apache.org
Received: (qmail 18116 invoked from network); 27 Mar 2009 09:35:14 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3)
  by minotaur.apache.org with SMTP; 27 Mar 2009 09:35:14 -0000
Received: (qmail 98887 invoked by uid 500); 27 Mar 2009 09:35:14 -0000
Delivered-To: apmail-camel-users-archive@camel.apache.org
Received: (qmail 98816 invoked by uid 500); 27 Mar 2009 09:35:14 -0000
Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:users-help@camel.apache.org>
List-Unsubscribe: <mailto:users-unsubscribe@camel.apache.org>
List-Post: <mailto:users@camel.apache.org>
List-Id: <users.camel.apache.org>
Reply-To: users@camel.apache.org
Delivered-To: mailing list users@camel.apache.org
Received: (qmail 98806 invoked by uid 99); 27 Mar 2009 09:35:14 -0000
Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230)
    by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 27 Mar 2009 09:35:14 +0000
X-ASF-Spam-Status: No, hits=0.2 required=10.0
	tests=SPF_PASS,WHOIS_MYPRIVREG
X-Spam-Check-By: apache.org
Received-SPF: pass (nike.apache.org: domain of claus.ibsen@gmail.com
 designates 209.85.218.178 as permitted sender)
Received: from [209.85.218.178] (HELO mail-bw0-f178.google.com)
 (209.85.218.178)
    by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 27 Mar 2009 09:35:03 +0000
Received: by bwz26 with SMTP id 26so921510bwz.20
        for <users@camel.apache.org>; Fri, 27 Mar 2009 02:34:42 -0700 (PDT)
DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
        d=gmail.com; s=gamma;
        h=domainkey-signature:mime-version:in-reply-to:references:date
         :received:message-id:subject:from:to:content-type
         :content-transfer-encoding;
        bh=2nbgwho16kETXAiPOdI1TbsMmVVn+4iLfD3wfMgK6AU=;
        b=lleKg3C8qGoAwcaOVXW0DFD3I3c8FSY0Y9e1YJe9La25lj7CjWousjulHF8Mhs6y1j
         2MaWNnYQaBPjIPrasa+/a3Ii2mkHGvG54uZmsJAud9kDcgd5xsy8kdeBjAxDVXXvAa37
         W64O9VrNuhdn1/2qLfftWav2vcM/3mMOmtB5Q=
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:in-reply-to:references:date:message-id:subject:from:to
         :content-type:content-transfer-encoding;
        b=Olbmx7uzWmkSA4Tkr6IAwRjurl4e2d89oCPIj6M+ZJ9y+3A/Pm8QFVt2cHa98ObRyN
         IhvL0iFr8lShJYXNOI4IrGwUbFTvyeQIk48oIMc3GBrtywTFEmB2tKHDEIyIG7ccdaP8
         NuilPAxN5zlNuVZb8NkBlyLGktlnyf5fNZnZI=
MIME-Version: 1.0
In-Reply-To: <22738110.post@talk.nabble.com>
References: <22725597.post@talk.nabble.com> <22725997.post@talk.nabble.com>
	<49CC3007.1070800@gmail.com> <22737641.post@talk.nabble.com>
	<49CC9333.3080105@gmail.com> <22738110.post@talk.nabble.com>
Date: Fri, 27 Mar 2009 10:34:27 +0100
Received: by 10.223.104.140 with SMTP id p12mr1474789fao.7.1238146482352;
 Fri,
	27 Mar 2009 02:34:42 -0700 (PDT)
Message-ID: <5380c69c0903270234v158c9c8v35f3f28e46e3cda7@mail.gmail.com>
Subject: Re: Camel 2.0 - Multicast issue ??
From: Claus Ibsen <claus.ibsen@gmail.com>
To: users@camel.apache.org
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable
X-Virus-Checked: Checked by ClamAV on apache.org

Hi

You can use the wireTap for fire and forget style DSL.

1)
However I currently does not support specifying multiple destinations
in one line.

2)
However I was wondering if we could improve the logic in multicast to
inspect the MEP and if not Out capable it should not wait/expect a
response.
Might be not east to do.



2009/3/27 cmoulliard <cmoulliard@gmail.com>:
>
> Hi Willem,
>
> Many thanks.
>
> By the way, It should be interesting to have a real parallel DSL word in =
the
> camel syntax for simple case like this.
>
> The route could be written with the assumption that no OUT message is wai=
ted
> by the calling process
>
> e.g.
>
> <from uri=3D"">
> ...
> <!-- at this point we don't wait any OUT message from endpoints called, o=
ur
> strategy is pure
> =A0 =A0 =A0FIRE/FORGET -->
> <parallel>
> =A0 <to uri=3D"direct:feedbackWS"/>
> =A0 <to uri=3D"direct:saveWS"/>
> </parrallel>
>
> An extension of this could be that parallel does not receive OUT message =
but
> properties or headers like e.g. parallelName=3D"feedbackWS",
> status=3D"processed" and we could provide a timer as a property.
>
> <parallel timer=3D"180" feedbackRequested=3D"true">
> ...
> </parallel>
>
> If one of the parallel process does not finish until the period defined b=
y
> the timer, then the parallel process generates errors.
>
> regards,
>
> Charles
>
>
>
>
> willem.jiang wrote:
>>
>> Hi Charles,
>>
>> Camel multicast supports to send the exchange parallely.
>> You just need to set the customer aggregation strategy to return a right
>> exchange for aggregation like this, since we don't when the bean's
>> exchange is returned.
>>
>> public class MyCustomerAggregationStrategy implements AggregationStrateg=
y
>> {
>> =A0 =A0 // only return the exchage which has the out message
>> =A0 =A0 public Exchange aggregate(Exchange oldExchange, Exchange newExch=
ange)
>> {
>> =A0 =A0 =A0 =A0 if (oldExchange.getOutMessage(false)!=3D null) {
>> =A0 =A0 =A0 =A0 =A0 =A0return oldExchange;
>> =A0 =A0 =A0 =A0 } else {
>> =A0 =A0 =A0 =A0 =A0 =A0return newExchange;
>> =A0 =A0 =A0 =A0 }
>> =A0 =A0 }
>> }
>>
>> Willem
>>
>>
>>
>> cmoulliard wrote:
>>> Many thanks Willem. In fact, I tried to use the multicast as a workarou=
nd
>>> because I was blocked to call directly the bean:feedback after the step
>>> converting the content of WS into InputReportIncident. I have the same
>>> problem as we have with the setHeader that you solved
>>>
>>> remark : In my case, it could be more interesting to send in parallel t=
he
>>> same message to two different endpoints (direct:feedbackWS and
>>> direct:saveWS).
>>>
>>> Nevertheless, I will try to adapt my multicast routes as you propose (p=
ut
>>> the "direct:feedbackWS" to the last endpoint) but for the moment I don'=
t
>>> how
>>> to achieve this.
>>>
>>> Regards,
>>>
>>> Charles
>>>
>>> So I will try to
>>>
>>> willem.jiang wrote:
>>>> Hi Charles,
>>>>
>>>> If you used the multicast for the InOut Message, Camel will try to
>>>> aggregate the exchange for the out message processing and the default
>>>> aggregation strategy is using the last exchange.
>>>>
>>>> You need to adjust the multicast endpoints in your Spring configuratio=
n
>>>> file, and put the "direct:feedbackWS" to the last endpoint, or you can
>>>> specify your own aggregation strategy in the multicast.
>>>>
>>>> You can find more examples about how to use multicast in the LoanBroke=
r
>>>> Example[1] of Camel.
>>>>
>>>> [1]http://cwiki.apache.org/CAMEL/loan-broker-example.html#LoanBrokerEx=
ample-Implementationwithwebservice
>>>>
>>>> Willem
>>>>
>>>>
>>>>
>>>> cmoulliard wrote:
>>>>> To solve the error returned and as proposed by Claus, I have modified
>>>>> my
>>>>> route like this
>>>>>
>>>>> <camel:inOnly uri=3D"queuingservice:queue:in" />
>>>>>
>>>>> Nevertheless, the multicast does not work as we can in the log here :
>>>>>
>>>>> 17:38:34,250 | INFO =A0| 25328218@qtp2-0 =A0| TraceInterceptor
>>>>> |
>>>>> rg.apache.camel.processor.Logger =A0 88 |
>>>>> ID-dell-charles-1751-1238084114250-2-7 >>>
>>>>> http://localhost:8080/camel-example/incident --> setHeader(webservice=
),
>>>>> Pattern:InOut,
>>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=3D[Bind=
ingOperationInfo:
>>>>> {http://reportincident.example.camel.apache.org}ReportIncident],
>>>>> CamelCXFDataFormat=3DPOJO}, Headers:{content-type=3Dtext/xml;charset=
=3DUTF-8,
>>>>> content.type=3Dtext/xml;charset=3DUTF-8, operationName=3DReportIncide=
nt,
>>>>> Host=3Dlocalhost:8080, Content-Length=3D640,
>>>>> SOAPAction=3D"http://reportincident.example.camel.apache.org/ReportIn=
cident",
>>>>> User-Agent=3DJakarta Commons-HttpClient/3.1,
>>>>> org.apache.cxf.headers.Header.list=3D[],
>>>>> operationNameSpace=3Dhttp://reportincident.example.camel.apache.org},
>>>>> BodyType:org.apache.cxf.message.MessageContentsList,
>>>>> Body:[org.apache.camel.example.reportincident.InputReportIncident@250=
f55]
>>>>> 17:38:34,265 | INFO =A0| 25328218@qtp2-0 =A0| TraceInterceptor
>>>>> |
>>>>> rg.apache.camel.processor.Logger =A0 88 |
>>>>> ID-dell-charles-1751-1238084114250-2-7 >>> setHeader(webservice) -->
>>>>> convertBodyTo(), Pattern:InOut,
>>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=3D[Bind=
ingOperationInfo:
>>>>> {http://reportincident.example.camel.apache.org}ReportIncident],
>>>>> CamelCXFDataFormat=3DPOJO}, Headers:{content-type=3Dtext/xml;charset=
=3DUTF-8,
>>>>> operationName=3DReportIncident, content.type=3Dtext/xml;charset=3DUTF=
-8,
>>>>> Host=3Dlocalhost:8080, Content-Length=3D640,
>>>>> SOAPAction=3D"http://reportincident.example.camel.apache.org/ReportIn=
cident",
>>>>> origin=3Dwebservice, User-Agent=3DJakarta Commons-HttpClient/3.1,
>>>>> operationNameSpace=3Dhttp://reportincident.example.camel.apache.org,
>>>>> org.apache.cxf.headers.Header.list=3D[]},
>>>>> BodyType:org.apache.cxf.message.MessageContentsList,
>>>>> Body:[org.apache.camel.example.reportincident.InputReportIncident@250=
f55]
>>>>> 17:38:34,265 | INFO =A0| 25328218@qtp2-0 =A0| TraceInterceptor
>>>>> |
>>>>> rg.apache.camel.processor.Logger =A0 88 |
>>>>> ID-dell-charles-1751-1238084114250-2-7 >>> convertBodyTo() -->
>>>>> multicast(),
>>>>> Pattern:InOut,
>>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=3D[Bind=
ingOperationInfo:
>>>>> {http://reportincident.example.camel.apache.org}ReportIncident],
>>>>> CamelCXFDataFormat=3DPOJO}, Headers:{content-type=3Dtext/xml;charset=
=3DUTF-8,
>>>>> operationName=3DReportIncident, content.type=3Dtext/xml;charset=3DUTF=
-8,
>>>>> Host=3Dlocalhost:8080, Content-Length=3D640,
>>>>> SOAPAction=3D"http://reportincident.example.camel.apache.org/ReportIn=
cident",
>>>>> origin=3Dwebservice, User-Agent=3DJakarta Commons-HttpClient/3.1,
>>>>> operationNameSpace=3Dhttp://reportincident.example.camel.apache.org,
>>>>> org.apache.cxf.headers.Header.list=3D[]},
>>>>> BodyType:org.apache.camel.example.reportincident.InputReportIncident,
>>>>> Body:org.apache.camel.example.reportincident.InputReportIncident@250f=
55
>>>>> 17:38:34,265 | INFO =A0| 25328218@qtp2-0 =A0| TraceInterceptor
>>>>> |
>>>>> rg.apache.camel.processor.Logger =A0 88 |
>>>>> ID-dell-charles-1751-1238084114250-2-7 >>> multicast() -->
>>>>> to(direct:feedbackWS), Pattern:InOut,
>>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=3D[Bind=
ingOperationInfo:
>>>>> {http://reportincident.example.camel.apache.org}ReportIncident],
>>>>> CamelCXFDataFormat=3DPOJO}, Headers:{content-type=3Dtext/xml;charset=
=3DUTF-8,
>>>>> content.type=3Dtext/xml;charset=3DUTF-8, operationName=3DReportIncide=
nt,
>>>>> Host=3Dlocalhost:8080, Content-Length=3D640, origin=3Dwebservice,
>>>>> SOAPAction=3D"http://reportincident.example.camel.apache.org/ReportIn=
cident",
>>>>> User-Agent=3DJakarta Commons-HttpClient/3.1,
>>>>> org.apache.cxf.headers.Header.list=3D[],
>>>>> operationNameSpace=3Dhttp://reportincident.example.camel.apache.org},
>>>>> BodyType:org.apache.camel.example.reportincident.InputReportIncident,
>>>>> Body:org.apache.camel.example.reportincident.InputReportIncident@250f=
55
>>>>> 17:38:34,281 | INFO =A0| 25328218@qtp2-0 =A0| TraceInterceptor
>>>>> |
>>>>> rg.apache.camel.processor.Logger =A0 88 |
>>>>> ID-dell-charles-1751-1238084114250-2-7 >>> to(direct:feedbackWS) -->
>>>>> transform(), Pattern:InOut,
>>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=3D[Bind=
ingOperationInfo:
>>>>> {http://reportincident.example.camel.apache.org}ReportIncident],
>>>>> CamelCXFDataFormat=3DPOJO}, Headers:{content-type=3Dtext/xml;charset=
=3DUTF-8,
>>>>> content.type=3Dtext/xml;charset=3DUTF-8, operationName=3DReportIncide=
nt,
>>>>> Host=3Dlocalhost:8080, Content-Length=3D640, origin=3Dwebservice,
>>>>> SOAPAction=3D"http://reportincident.example.camel.apache.org/ReportIn=
cident",
>>>>> User-Agent=3DJakarta Commons-HttpClient/3.1,
>>>>> org.apache.cxf.headers.Header.list=3D[],
>>>>> operationNameSpace=3Dhttp://reportincident.example.camel.apache.org},
>>>>> BodyType:org.apache.camel.example.reportincident.InputReportIncident,
>>>>> Body:org.apache.camel.example.reportincident.InputReportIncident@250f=
55
>>>>> 17:38:34,281 | INFO =A0| 25328218@qtp2-0 =A0| TraceInterceptor
>>>>> |
>>>>> rg.apache.camel.processor.Logger =A0 88 |
>>>>> ID-dell-charles-1751-1238084114250-2-7 >>> transform() -->
>>>>> to(direct:saveWS), Pattern:InOut,
>>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=3D[Bind=
ingOperationInfo:
>>>>> {http://reportincident.example.camel.apache.org}ReportIncident],
>>>>> CamelCXFDataFormat=3DPOJO}, Headers:{content-type=3Dtext/xml;charset=
=3DUTF-8,
>>>>> content.type=3Dtext/xml;charset=3DUTF-8, operationName=3DReportIncide=
nt,
>>>>> Host=3Dlocalhost:8080, Content-Length=3D640, origin=3Dwebservice,
>>>>> SOAPAction=3D"http://reportincident.example.camel.apache.org/ReportIn=
cident",
>>>>> User-Agent=3DJakarta Commons-HttpClient/3.1,
>>>>> org.apache.cxf.headers.Header.list=3D[],
>>>>> operationNameSpace=3Dhttp://reportincident.example.camel.apache.org},
>>>>> BodyType:org.apache.camel.example.reportincident.InputReportIncident,
>>>>> Body:org.apache.camel.example.reportincident.InputReportIncident@250f=
55
>>>>> 17:38:34,296 | INFO =A0| 25328218@qtp2-0 =A0| TraceInterceptor
>>>>> |
>>>>> rg.apache.camel.processor.Logger =A0 88 |
>>>>> ID-dell-charles-1751-1238084114250-2-7 >>> to(direct:saveWS) -->
>>>>> to(bean:webservice), Pattern:InOut,
>>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=3D[Bind=
ingOperationInfo:
>>>>> {http://reportincident.example.camel.apache.org}ReportIncident],
>>>>> CamelCXFDataFormat=3DPOJO}, Headers:{content-type=3Dtext/xml;charset=
=3DUTF-8,
>>>>> content.type=3Dtext/xml;charset=3DUTF-8, operationName=3DReportIncide=
nt,
>>>>> Host=3Dlocalhost:8080, Content-Length=3D640, origin=3Dwebservice,
>>>>> SOAPAction=3D"http://reportincident.example.camel.apache.org/ReportIn=
cident",
>>>>> User-Agent=3DJakarta Commons-HttpClient/3.1,
>>>>> org.apache.cxf.headers.Header.list=3D[],
>>>>> operationNameSpace=3Dhttp://reportincident.example.camel.apache.org},
>>>>> BodyType:org.apache.camel.example.reportincident.InputReportIncident,
>>>>> Body:org.apache.camel.example.reportincident.InputReportIncident@250f=
55
>>>>> 17:38:34,312 | INFO =A0| 25328218@qtp2-0 =A0| TraceInterceptor
>>>>> |
>>>>> rg.apache.camel.processor.Logger =A0 88 |
>>>>> ID-dell-charles-1751-1238084114250-2-7 >>> to(bean:webservice) -->
>>>>> inOnly(queuingservice:queue:in), Pattern:InOut,
>>>>> Properties:{CamelBeanHolder=3Dbean: webservice,
>>>>> org.apache.cxf.service.model.BindingOperationInfo=3D[BindingOperation=
Info:
>>>>> {http://reportincident.example.camel.apache.org}ReportIncident],
>>>>> CamelCXFDataFormat=3DPOJO}, BodyType:java.util.ArrayList,
>>>>> Body:[{org.apache.camel.example.reportincident.model.Incident=3Dorg.a=
pache.camel.example.reportincident.model.Incident@e22502[
>>>>> =A0 incidentId=3D0
>>>>> =A0 incidentRef=3D20
>>>>> =A0 incidentDate=3D<null>
>>>>> =A0 givenName=3DCharles
>>>>> =A0 familyName=3DMoulliard
>>>>> =A0 summary=3DThis is an OSGI report incident
>>>>> =A0 details=3Dnothing to say
>>>>> =A0 email=3Dcmoulliard@xpectis.com
>>>>> =A0 phone=3D+352 25 10 70 470
>>>>> =A0 creationUser=3D<null>
>>>>> =A0 creationDate=3D<null>
>>>>> ]}]
>>>>> 17:38:34,343 | INFO =A0| ActiveMQ Task =A0 =A0| FailoverTransport
>>>>> |
>>>>> sport.failover.FailoverTransport =A0714 | Successfully connected to
>>>>> tcp://localhost:61616
>>>>> 17:38:34,437 | INFO =A0| enerContainer-35 | TraceInterceptor
>>>>> |
>>>>> rg.apache.camel.processor.Logger =A0 88 |
>>>>> ID-dell-charles-1751-1238084114250-2-8 >>> queuingservice:queue:in --=
>
>>>>> to(bean:incidentSaver?method=3Dprocess), Pattern:InOnly,
>>>>> Headers:{JMSXGroupID=3Dnull, JMSCorrelationID=3Dnull, JMSType=3Dnull,
>>>>> JMSExpiration=3D0,
>>>>> JMSMessageID=3DID:dell-charles-1712-1238084102453-2:3:1:1:1,
>>>>> JMSRedelivered=3Dfalse, JMSDeliveryMode=3D2, JMSPriority=3D4,
>>>>> JMSReplyTo=3Dnull,
>>>>> JMSTimestamp=3D1238085514359, JMSDestination=3Dqueue://in},
>>>>> BodyType:java.util.ArrayList,
>>>>> Body:[{org.apache.camel.example.reportincident.model.Incident=3Dorg.a=
pache.camel.example.reportincident.model.Incident@f0bca1[
>>>>> =A0 incidentId=3D0
>>>>> =A0 incidentRef=3D20
>>>>> =A0 incidentDate=3D<null>
>>>>> =A0 givenName=3DCharles
>>>>> =A0 familyName=3DMoulliard
>>>>> =A0 summary=3DThis is an OSGI report incident
>>>>> =A0 details=3Dnothing to say
>>>>> =A0 email=3Dcmoulliard@xpectis.com
>>>>> =A0 phone=3D+352 25 10 70 470
>>>>> =A0 creationUser=3D<null>
>>>>> =A0 creationDate=3D<null>
>>>>> ]}]
>>>>> 17:38:34,421 | INFO =A0| 25328218@qtp2-0 =A0| PhaseInterceptorChain
>>>>> |
>>>>> ransport.ChainInitiationObserver =A0 89 | Interceptor has thrown
>>>>> exception,
>>>>> unwinding now
>>>>> org.apache.cxf.interceptor.Fault: Marshalling Error: class
>>>>> java.util.HashMap
>>>>> nor any of its super class is known to this context.
>>>>> =A0 =A0at
>>>>> org.apache.cxf.jaxb.JAXBEncoderDecoder.marshall(JAXBEncoderDecoder.ja=
va:159)
>>>>> =A0 =A0at
>>>>> org.apache.cxf.jaxb.io.DataWriterImpl.write(DataWriterImpl.java:169)
>>>>> =A0 =A0at
>>>>> org.apache.cxf.interceptor.AbstractOutDatabindingInterceptor.writePar=
ts(AbstractOutDatabindingInterceptor.java:104)
>>>>> =A0 =A0at
>>>>> org.apache.cxf.interceptor.BareOutInterceptor.handleMessage(BareOutIn=
terceptor.java:68)
>>>>> =A0 =A0at
>>>>> org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseIntercept=
orChain.java:236)
>>>>> =A0 =A0at
>>>>> org.apache.cxf.interceptor.OutgoingChainInterceptor.handleMessage(Out=
goingChainInterceptor.java:74)
>>>>> =A0 =A0at
>>>>> org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseIntercept=
orChain.java:236)
>>>>> =A0 =A0at
>>>>> org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainIniti=
ationObserver.java:89)
>>>>> =A0 =A0at
>>>>> org.apache.cxf.transport.http_jetty.JettyHTTPDestination.serviceReque=
st(JettyHTTPDestination.java:302)
>>>>> =A0 =A0at
>>>>> org.apache.cxf.transport.http_jetty.JettyHTTPDestination.doService(Je=
ttyHTTPDestination.java:265)
>>>>> =A0 =A0at
>>>>> org.apache.cxf.transport.http_jetty.JettyHTTPHandler.handle(JettyHTTP=
Handler.java:70)
>>>>> =A0 =A0at
>>>>> org.mortbay.jetty.handler.ContextHandler.handle(ContextHandler.java:7=
66)
>>>>> =A0 =A0at
>>>>> org.mortbay.jetty.handler.ContextHandlerCollection.handle(ContextHand=
lerCollection.java:230)
>>>>> =A0 =A0at
>>>>> org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:1=
52)
>>>>> =A0 =A0at org.mortbay.jetty.Server.handle(Server.java:324)
>>>>> =A0 =A0at
>>>>> org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:53=
4)
>>>>> =A0 =A0at
>>>>> org.mortbay.jetty.HttpConnection$RequestHandler.content(HttpConnectio=
n.java:879)
>>>>> =A0 =A0at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:741)
>>>>> =A0 =A0at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java=
:213)
>>>>> =A0 =A0at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java=
:403)
>>>>> =A0 =A0at
>>>>> org.mortbay.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.ja=
va:409)
>>>>> =A0 =A0at
>>>>> org.mortbay.thread.QueuedThreadPool$PoolThread.run(QueuedThreadPool.j=
ava:522)
>>>>> Caused by: javax.xml.bind.MarshalException
>>>>> =A0- with linked exception:
>>>>> [javax.xml.bind.JAXBException: class java.util.HashMap nor any of its
>>>>> super
>>>>> class is known to this context.]
>>>>> =A0 =A0at
>>>>> com.sun.xml.bind.v2.runtime.MarshallerImpl.write(MarshallerImpl.java:=
331)
>>>>> =A0 =A0at
>>>>> com.sun.xml.bind.v2.runtime.MarshallerImpl.marshal(MarshallerImpl.jav=
a:257)
>>>>> =A0 =A0at
>>>>> javax.xml.bind.helpers.AbstractMarshallerImpl.marshal(AbstractMarshal=
lerImpl.java:100)
>>>>> =A0 =A0at
>>>>> org.apache.cxf.jaxb.JAXBEncoderDecoder.writeObject(JAXBEncoderDecoder=
.java:441)
>>>>> =A0 =A0at
>>>>> org.apache.cxf.jaxb.JAXBEncoderDecoder.marshall(JAXBEncoderDecoder.ja=
va:138)
>>>>> =A0 =A0... 21 more
>>>>> Caused by: javax.xml.bind.JAXBException: class java.util.HashMap nor
>>>>> any
>>>>> of
>>>>> its super class is known to this context.
>>>>> =A0 =A0at
>>>>> com.sun.xml.bind.v2.runtime.XMLSerializer.reportError(XMLSerializer.j=
ava:242)
>>>>> =A0 =A0at
>>>>> com.sun.xml.bind.v2.runtime.XMLSerializer.reportError(XMLSerializer.j=
ava:257)
>>>>> =A0 =A0at
>>>>> com.sun.xml.bind.v2.runtime.XMLSerializer.childAsXsiType(XMLSerialize=
r.java:649)
>>>>> =A0 =A0at
>>>>> com.sun.xml.bind.v2.runtime.property.SingleElementNodeProperty.serial=
izeBody(SingleElementNodeProperty.java:147)
>>>>> =A0 =A0at
>>>>> com.sun.xml.bind.v2.runtime.ElementBeanInfoImpl$1.serializeBody(Eleme=
ntBeanInfoImpl.java:156)
>>>>> =A0 =A0at
>>>>> com.sun.xml.bind.v2.runtime.ElementBeanInfoImpl$1.serializeBody(Eleme=
ntBeanInfoImpl.java:185)
>>>>> =A0 =A0at
>>>>> com.sun.xml.bind.v2.runtime.ElementBeanInfoImpl.serializeBody(Element=
BeanInfoImpl.java:305)
>>>>> =A0 =A0at
>>>>> com.sun.xml.bind.v2.runtime.ElementBeanInfoImpl.serializeRoot(Element=
BeanInfoImpl.java:312)
>>>>> =A0 =A0at
>>>>> com.sun.xml.bind.v2.runtime.ElementBeanInfoImpl.serializeRoot(Element=
BeanInfoImpl.java:71)
>>>>> =A0 =A0at
>>>>> com.sun.xml.bind.v2.runtime.XMLSerializer.childAsRoot(XMLSerializer.j=
ava:490)
>>>>> =A0 =A0at
>>>>> com.sun.xml.bind.v2.runtime.MarshallerImpl.write(MarshallerImpl.java:=
328)
>>>>> =A0 =A0... 25 more
>>>>> Caused by: javax.xml.bind.JAXBException: class java.util.HashMap nor
>>>>> any
>>>>> of
>>>>> its super class is known to this context.
>>>>> =A0 =A0at
>>>>> com.sun.xml.bind.v2.runtime.JAXBContextImpl.getBeanInfo(JAXBContextIm=
pl.java:556)
>>>>> =A0 =A0at
>>>>> com.sun.xml.bind.v2.runtime.XMLSerializer.childAsXsiType(XMLSerialize=
r.java:644)
>>>>> =A0 =A0... 33 more
>>>>>
>>>>> cmoulliard wrote:
>>>>>> Hi,
>>>>>>
>>>>>> I have defined the following routes in camel :
>>>>>>
>>>>>> =A0 =A0 =A0 =A0 =A0 <!-- Receive WS message, multicast the message a=
nd provive feedback
>>>>>> -->
>>>>>> =A0 =A0 =A0 =A0 =A0 <camel:route>
>>>>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 <camel:from uri=3D"cxf:bean:repo=
rtIncident" />
>>>>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 <!-- issue resolved 26/03/2009 -=
->
>>>>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 <camel:setHeader headerName=3D"o=
rigin">
>>>>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 <camel:constant>=
webservice</camel:constant>
>>>>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 </camel:setHeader>
>>>>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 <camel:convertBodyTo
>>>>>> type=3D"org.apache.camel.example.reportincident.InputReportIncident"=
 />
>>>>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 <camel:multicast>
>>>>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 <camel:to uri=3D=
"direct:feedbackWS"/>
>>>>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 <camel:to uri=3D=
"direct:saveWS"/>
>>>>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 </camel:multicast>
>>>>>> =A0 =A0 =A0 =A0 =A0 </camel:route>
>>>>>>
>>>>>> =A0 =A0 =A0 =A0 =A0 <!-- =A0Send feedback to WebService -->
>>>>>> =A0 =A0 =A0 =A0 =A0 <camel:route>
>>>>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 <camel:from uri=3D"direct:feedbackWS" />
>>>>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 <camel:transform>
>>>>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 <camel:method be=
an=3D"feedback" method=3D"setOk" />
>>>>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 </camel:transform>
>>>>>> =A0 =A0 =A0 =A0 =A0 </camel:route>
>>>>>>
>>>>>> =A0 =A0 =A0 =A0 =A0 <!-- Convert WS message and put it in the queue =
=A0-->
>>>>>> =A0 =A0 =A0 =A0 =A0 <camel:route>
>>>>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 <camel:from uri=3D"direct:saveWS" />
>>>>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 <camel:to uri=3D"bean:webservice=
" />
>>>>>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 <camel:to uri=3D"queuingservice:=
queue:in" />
>>>>>> =A0 =A0 =A0 =A0 =A0 </camel:route>
>>>>>>
>>>>>> When calling the web service, we can see in the trace that the proce=
ss
>>>>>> starts correctly but the multicast seems to mix the routes and a err=
or
>>>>>> is
>>>>>> generated :
>>>>>>
>>>>>> 17:16:08,562 | INFO =A0| 12773899@qtp1-0 =A0| TraceInterceptor
>>>>>> | rg.apache.camel.processor.Logger =A0 88 |
>>>>>> ID-dell-charles-1751-1238084114250-2-0 >>>
>>>>>> http://localhost:8080/camel-example/incident -->
>>>>>> setHeader(webservice),
>>>>>> Pattern:InOut,
>>>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=3D[Bin=
dingOperationInfo:
>>>>>> {http://reportincident.example.camel.apache.org}ReportIncident],
>>>>>> CamelCXFDataFormat=3DPOJO},
>>>>>> Headers:{content-type=3Dtext/xml;charset=3DUTF-8,
>>>>>> content.type=3Dtext/xml;charset=3DUTF-8, operationName=3DReportIncid=
ent,
>>>>>> Host=3Dlocalhost:8080, Content-Length=3D640,
>>>>>> SOAPAction=3D"http://reportincident.example.camel.apache.org/ReportI=
ncident",
>>>>>> User-Agent=3DJakarta Commons-HttpClient/3.1,
>>>>>> org.apache.cxf.headers.Header.list=3D[],
>>>>>> operationNameSpace=3Dhttp://reportincident.example.camel.apache.org}=
,
>>>>>> BodyType:org.apache.cxf.message.MessageContentsList,
>>>>>> Body:[org.apache.camel.example.reportincident.InputReportIncident@ea=
9f6e]
>>>>>>
>>>>>> 17:16:08,578 | INFO =A0| 12773899@qtp1-0 =A0| TraceInterceptor
>>>>>> | rg.apache.camel.processor.Logger =A0 88 |
>>>>>> ID-dell-charles-1751-1238084114250-2-0 >>> setHeader(webservice) -->
>>>>>> convertBodyTo(), Pattern:InOut,
>>>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=3D[Bin=
dingOperationInfo:
>>>>>> {http://reportincident.example.camel.apache.org}ReportIncident],
>>>>>> CamelCXFDataFormat=3DPOJO},
>>>>>> Headers:{content-type=3Dtext/xml;charset=3DUTF-8,
>>>>>> operationName=3DReportIncident, content.type=3Dtext/xml;charset=3DUT=
F-8,
>>>>>> Host=3Dlocalhost:8080, Content-Length=3D640,
>>>>>> SOAPAction=3D"http://reportincident.example.camel.apache.org/ReportI=
ncident",
>>>>>> origin=3Dwebservice, User-Agent=3DJakarta Commons-HttpClient/3.1,
>>>>>> operationNameSpace=3Dhttp://reportincident.example.camel.apache.org,
>>>>>> org.apache.cxf.headers.Header.list=3D[]},
>>>>>> BodyType:org.apache.cxf.message.MessageContentsList,
>>>>>> Body:[org.apache.camel.example.reportincident.InputReportIncident@ea=
9f6e]
>>>>>>
>>>>>> 17:16:08,578 | INFO =A0| 12773899@qtp1-0 =A0| TraceInterceptor
>>>>>> | rg.apache.camel.processor.Logger =A0 88 |
>>>>>> ID-dell-charles-1751-1238084114250-2-0 >>> convertBodyTo() -->
>>>>>> multicast(), Pattern:InOut,
>>>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=3D[Bin=
dingOperationInfo:
>>>>>> {http://reportincident.example.camel.apache.org}ReportIncident],
>>>>>> CamelCXFDataFormat=3DPOJO},
>>>>>> Headers:{content-type=3Dtext/xml;charset=3DUTF-8,
>>>>>> operationName=3DReportIncident, content.type=3Dtext/xml;charset=3DUT=
F-8,
>>>>>> Host=3Dlocalhost:8080, Content-Length=3D640,
>>>>>> SOAPAction=3D"http://reportincident.example.camel.apache.org/ReportI=
ncident",
>>>>>> origin=3Dwebservice, User-Agent=3DJakarta Commons-HttpClient/3.1,
>>>>>> operationNameSpace=3Dhttp://reportincident.example.camel.apache.org,
>>>>>> org.apache.cxf.headers.Header.list=3D[]},
>>>>>> BodyType:org.apache.camel.example.reportincident.InputReportIncident=
,
>>>>>> Body:org.apache.camel.example.reportincident.InputReportIncident@ea9=
f6e
>>>>>>
>>>>>> 17:16:08,593 | INFO =A0| 12773899@qtp1-0 =A0| TraceInterceptor
>>>>>> | rg.apache.camel.processor.Logger =A0 88 |
>>>>>> ID-dell-charles-1751-1238084114250-2-0 >>> multicast() -->
>>>>>> to(direct:feedbackWS), Pattern:InOut,
>>>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=3D[Bin=
dingOperationInfo:
>>>>>> {http://reportincident.example.camel.apache.org}ReportIncident],
>>>>>> CamelCXFDataFormat=3DPOJO},
>>>>>> Headers:{content-type=3Dtext/xml;charset=3DUTF-8,
>>>>>> content.type=3Dtext/xml;charset=3DUTF-8, operationName=3DReportIncid=
ent,
>>>>>> Host=3Dlocalhost:8080, Content-Length=3D640, origin=3Dwebservice,
>>>>>> SOAPAction=3D"http://reportincident.example.camel.apache.org/ReportI=
ncident",
>>>>>> User-Agent=3DJakarta Commons-HttpClient/3.1,
>>>>>> org.apache.cxf.headers.Header.list=3D[],
>>>>>> operationNameSpace=3Dhttp://reportincident.example.camel.apache.org}=
,
>>>>>> BodyType:org.apache.camel.example.reportincident.InputReportIncident=
,
>>>>>> Body:org.apache.camel.example.reportincident.InputReportIncident@ea9=
f6e
>>>>>>
>>>>>> 17:16:08,593 | INFO =A0| 12773899@qtp1-0 =A0| TraceInterceptor
>>>>>> | rg.apache.camel.processor.Logger =A0 88 |
>>>>>> ID-dell-charles-1751-1238084114250-2-0 >>> to(direct:feedbackWS) -->
>>>>>> transform(), Pattern:InOut,
>>>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=3D[Bin=
dingOperationInfo:
>>>>>> {http://reportincident.example.camel.apache.org}ReportIncident],
>>>>>> CamelCXFDataFormat=3DPOJO},
>>>>>> Headers:{content-type=3Dtext/xml;charset=3DUTF-8,
>>>>>> content.type=3Dtext/xml;charset=3DUTF-8, operationName=3DReportIncid=
ent,
>>>>>> Host=3Dlocalhost:8080, Content-Length=3D640, origin=3Dwebservice,
>>>>>> SOAPAction=3D"http://reportincident.example.camel.apache.org/ReportI=
ncident",
>>>>>> User-Agent=3DJakarta Commons-HttpClient/3.1,
>>>>>> org.apache.cxf.headers.Header.list=3D[],
>>>>>> operationNameSpace=3Dhttp://reportincident.example.camel.apache.org}=
,
>>>>>> BodyType:org.apache.camel.example.reportincident.InputReportIncident=
,
>>>>>> Body:org.apache.camel.example.reportincident.InputReportIncident@ea9=
f6e
>>>>>>
>>>>>> 17:16:08,625 | INFO =A0| 12773899@qtp1-0 =A0| TraceInterceptor
>>>>>> | rg.apache.camel.processor.Logger =A0 88 |
>>>>>> ID-dell-charles-1751-1238084114250-2-0 >>> transform() -->
>>>>>> to(direct:saveWS), Pattern:InOut,
>>>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=3D[Bin=
dingOperationInfo:
>>>>>> {http://reportincident.example.camel.apache.org}ReportIncident],
>>>>>> CamelCXFDataFormat=3DPOJO},
>>>>>> Headers:{content-type=3Dtext/xml;charset=3DUTF-8,
>>>>>> content.type=3Dtext/xml;charset=3DUTF-8, operationName=3DReportIncid=
ent,
>>>>>> Host=3Dlocalhost:8080, Content-Length=3D640, origin=3Dwebservice,
>>>>>> SOAPAction=3D"http://reportincident.example.camel.apache.org/ReportI=
ncident",
>>>>>> User-Agent=3DJakarta Commons-HttpClient/3.1,
>>>>>> org.apache.cxf.headers.Header.list=3D[],
>>>>>> operationNameSpace=3Dhttp://reportincident.example.camel.apache.org}=
,
>>>>>> BodyType:org.apache.camel.example.reportincident.InputReportIncident=
,
>>>>>> Body:org.apache.camel.example.reportincident.InputReportIncident@ea9=
f6e
>>>>>>
>>>>>> 17:16:08,640 | INFO =A0| 12773899@qtp1-0 =A0| TraceInterceptor
>>>>>> | rg.apache.camel.processor.Logger =A0 88 |
>>>>>> ID-dell-charles-1751-1238084114250-2-0 >>> to(direct:saveWS) -->
>>>>>> to(bean:webservice), Pattern:InOut,
>>>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=3D[Bin=
dingOperationInfo:
>>>>>> {http://reportincident.example.camel.apache.org}ReportIncident],
>>>>>> CamelCXFDataFormat=3DPOJO},
>>>>>> Headers:{content-type=3Dtext/xml;charset=3DUTF-8,
>>>>>> content.type=3Dtext/xml;charset=3DUTF-8, operationName=3DReportIncid=
ent,
>>>>>> Host=3Dlocalhost:8080, Content-Length=3D640, origin=3Dwebservice,
>>>>>> SOAPAction=3D"http://reportincident.example.camel.apache.org/ReportI=
ncident",
>>>>>> User-Agent=3DJakarta Commons-HttpClient/3.1,
>>>>>> org.apache.cxf.headers.Header.list=3D[],
>>>>>> operationNameSpace=3Dhttp://reportincident.example.camel.apache.org}=
,
>>>>>> BodyType:org.apache.camel.example.reportincident.InputReportIncident=
,
>>>>>> Body:org.apache.camel.example.reportincident.InputReportIncident@ea9=
f6e
>>>>>>
>>>>>> 17:16:08,671 | INFO =A0| 12773899@qtp1-0 =A0| TraceInterceptor
>>>>>> | rg.apache.camel.processor.Logger =A0 88 |
>>>>>> ID-dell-charles-1751-1238084114250-2-0 >>> to(bean:webservice) -->
>>>>>> to(queuingservice:queue:in), Pattern:InOut,
>>>>>> Properties:{CamelBeanHolder=3Dbean: webservice,
>>>>>> org.apache.cxf.service.model.BindingOperationInfo=3D[BindingOperatio=
nInfo:
>>>>>> {http://reportincident.example.camel.apache.org}ReportIncident],
>>>>>> CamelCXFDataFormat=3DPOJO}, BodyType:java.util.ArrayList,
>>>>>> Body:[{org.apache.camel.example.reportincident.model.Incident=3Dorg.=
apache.camel.example.reportincident.model.Incident@14bbd50[
>>>>>> =A0 incidentId=3D0
>>>>>> =A0 incidentRef=3D20
>>>>>> =A0 incidentDate=3D<null>
>>>>>> =A0 givenName=3DCharles
>>>>>> =A0 familyName=3DMoulliard
>>>>>> =A0 summary=3DThis is an OSGI report incident
>>>>>> =A0 details=3Dnothing to say
>>>>>> =A0 email=3Dcmoulliard@xpectis.com
>>>>>> =A0 phone=3D+352 25 10 70 470
>>>>>> =A0 creationUser=3D<null>
>>>>>> =A0 creationDate=3D<null>
>>>>>> ]}]
>>>>>> 17:16:08,750 | INFO =A0| ActiveMQ Task =A0 =A0| FailoverTransport
>>>>>> | sport.failover.FailoverTransport =A0714 | Successfully connected t=
o
>>>>>> tcp://localhost:61616
>>>>>> 17:16:09,046 | INFO =A0| enerContainer-55 | TraceInterceptor
>>>>>> | rg.apache.camel.processor.Logger =A0 88 |
>>>>>> ID-dell-charles-1751-1238084114250-2-1 >>> queuingservice:queue:in -=
->
>>>>>> to(bean:incidentSaver?method=3Dprocess), Pattern:InOut,
>>>>>> Properties:{JMSReplyTo=3Dtemp-queue://ID:dell-charles-1712-123808410=
2453-2:1:1},
>>>>>> Headers:{JMSXGroupID=3Dnull,
>>>>>> JMSCorrelationID=3DID-dell-charles-1751-1238084114250-3-0, JMSType=
=3Dnull,
>>>>>> JMSExpiration=3D1238084188953,
>>>>>> JMSMessageID=3DID:dell-charles-1712-1238084102453-2:1:2:1:1,
>>>>>> JMSRedelivered=3Dfalse, JMSDeliveryMode=3D2, JMSPriority=3D4,
>>>>>> JMSReplyTo=3Dtemp-queue://ID:dell-charles-1712-1238084102453-2:1:1,
>>>>>> JMSTimestamp=3D1238084168953, JMSDestination=3Dqueue://in},
>>>>>> BodyType:java.util.ArrayList,
>>>>>> Body:[{org.apache.camel.example.reportincident.model.Incident=3Dorg.=
apache.camel.example.reportincident.model.Incident@127d19d[
>>>>>> =A0 incidentId=3D0
>>>>>> =A0 incidentRef=3D20
>>>>>> =A0 incidentDate=3D<null>
>>>>>> =A0 givenName=3DCharles
>>>>>> =A0 familyName=3DMoulliard
>>>>>> =A0 summary=3DThis is an OSGI report incident
>>>>>> =A0 details=3Dnothing to say
>>>>>> =A0 email=3Dcmoulliard@xpectis.com
>>>>>> =A0 phone=3D+352 25 10 70 470
>>>>>> =A0 creationUser=3D<null>
>>>>>> =A0 creationDate=3D<null>
>>>>>> ]}]
>>>>>> 17:16:31,250 | ERROR | 12773899@qtp1-0 =A0| DeadLetterChannel
>>>>>> | rg.apache.camel.processor.Logger =A0207 | Failed delivery for
>>>>>> exchangeId:
>>>>>> ID-dell-charles-1751-1238084114250-0-1. On delivery attempt: 0 caugh=
t:
>>>>>> org.apache.camel.ExchangeTimedOutException: The OUT message was not
>>>>>> received within: 20000 millis on the exchange: Exchange[Message:
>>>>>> [{org.apache.camel.example.reportincident.model.Incident=3Dorg.apach=
e.camel.example.reportincident.model.Incident@14bbd50[
>>>>>> =A0 incidentId=3D0
>>>>>> =A0 incidentRef=3D20
>>>>>> =A0 incidentDate=3D<null>
>>>>>> =A0 givenName=3DCharles
>>>>>> =A0 familyName=3DMoulliard
>>>>>> =A0 summary=3DThis is an OSGI report incident
>>>>>> =A0 details=3Dnothing to say
>>>>>> =A0 email=3Dcmoulliard@xpectis.com
>>>>>> =A0 phone=3D+352 25 10 70 470
>>>>>> =A0 creationUser=3D<null>
>>>>>> =A0 creationDate=3D<null>
>>>>>> ]}]]
>>>>>> org.apache.camel.ExchangeTimedOutException: The OUT message was not
>>>>>> received within: 20000 millis on the exchange: Exchange[Message:
>>>>>> [{org.apache.camel.example.reportincident.model.Incident=3Dorg.apach=
e.camel.example.reportincident.model.Incident@14bbd50[
>>>>>> =A0 incidentId=3D0
>>>>>> =A0 incidentRef=3D20
>>>>>> =A0 incidentDate=3D<null>
>>>>>> =A0 givenName=3DCharles
>>>>>> =A0 familyName=3DMoulliard
>>>>>> =A0 summary=3DThis is an OSGI report incident
>>>>>> =A0 details=3Dnothing to say
>>>>>> =A0 email=3Dcmoulliard@xpectis.com
>>>>>> =A0 phone=3D+352 25 10 70 470
>>>>>> =A0 creationUser=3D<null>
>>>>>> =A0 creationDate=3D<null>
>>>>>> ]}]]
>>>>>> =A0 at
>>>>>> org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:=
269)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:=
69)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.DelegateProcessor.processNext(DelegatePro=
cessor.java:49)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcess=
or.java:78)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.interceptor.TraceInterceptor.process(Trac=
eInterceptor.java:115)
>>>>>> =A0 at
>>>>>> org.apache.camel.management.InstrumentationProcessor.process(Instrum=
entationProcessor.java:80)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.proc=
eed(StreamCachingInterceptor.java:83)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.proc=
ess(StreamCachingInterceptor.java:78)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.DeadLetterChannel.process(DeadLetterChann=
el.java:204)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.DeadLetterChannel.process(DeadLetterChann=
el.java:145)
>>>>>> =A0 at org.apache.camel.processor.Pipeline.process(Pipeline.java:115=
)
>>>>>> =A0 at org.apache.camel.processor.Pipeline.process(Pipeline.java:89)
>>>>>> =A0 at
>>>>>> org.apache.camel.management.InstrumentationProcessor.process(Instrum=
entationProcessor.java:68)
>>>>>> =A0 at
>>>>>> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHel=
per.java:41)
>>>>>> =A0 at
>>>>>> org.apache.camel.management.InstrumentationProcessor.process(Instrum=
entationProcessor.java:55)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.DelegateProcessor.processNext(DelegatePro=
cessor.java:49)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcess=
or.java:78)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.interceptor.TraceInterceptor.process(Trac=
eInterceptor.java:115)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.proc=
eed(StreamCachingInterceptor.java:86)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.proc=
ess(StreamCachingInterceptor.java:78)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkPro=
cessor.java:70)
>>>>>> =A0 at
>>>>>> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHel=
per.java:41)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAs=
yncProcessor.java:65)
>>>>>> =A0 at
>>>>>> org.apache.camel.component.direct.DirectProducer.process(DirectProdu=
cer.java:47)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:=
69)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.DelegateProcessor.processNext(DelegatePro=
cessor.java:49)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcess=
or.java:78)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.interceptor.TraceInterceptor.process(Trac=
eInterceptor.java:115)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.proc=
eed(StreamCachingInterceptor.java:86)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.proc=
ess(StreamCachingInterceptor.java:78)
>>>>>> =A0 at
>>>>>> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHel=
per.java:41)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.proc=
ess(StreamCachingInterceptor.java:68)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.MulticastProcessor.process(MulticastProce=
ssor.java:191)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.proc=
eed(StreamCachingInterceptor.java:86)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.proc=
ess(StreamCachingInterceptor.java:78)
>>>>>> =A0 at
>>>>>> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHel=
per.java:41)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.proc=
ess(StreamCachingInterceptor.java:68)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.DelegateProcessor.processNext(DelegatePro=
cessor.java:49)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcess=
or.java:78)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.interceptor.TraceInterceptor.process(Trac=
eInterceptor.java:115)
>>>>>> =A0 at
>>>>>> org.apache.camel.management.InstrumentationProcessor.process(Instrum=
entationProcessor.java:80)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.proc=
eed(StreamCachingInterceptor.java:83)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.proc=
ess(StreamCachingInterceptor.java:78)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.DeadLetterChannel.process(DeadLetterChann=
el.java:204)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.DeadLetterChannel.process(DeadLetterChann=
el.java:145)
>>>>>> =A0 at org.apache.camel.processor.Pipeline.process(Pipeline.java:115=
)
>>>>>> =A0 at org.apache.camel.processor.Pipeline.process(Pipeline.java:89)
>>>>>> =A0 at
>>>>>> org.apache.camel.management.InstrumentationProcessor.process(Instrum=
entationProcessor.java:68)
>>>>>> =A0 at
>>>>>> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHel=
per.java:41)
>>>>>> =A0 at
>>>>>> org.apache.camel.management.InstrumentationProcessor.process(Instrum=
entationProcessor.java:55)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.DelegateProcessor.processNext(DelegatePro=
cessor.java:49)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcess=
or.java:78)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.interceptor.TraceInterceptor.process(Trac=
eInterceptor.java:115)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.proc=
eed(StreamCachingInterceptor.java:86)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.proc=
ess(StreamCachingInterceptor.java:78)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkPro=
cessor.java:52)
>>>>>> =A0 at
>>>>>> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHel=
per.java:41)
>>>>>> =A0 at
>>>>>> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAs=
yncProcessor.java:65)
>>>>>> =A0 at
>>>>>> org.apache.camel.component.cxf.CxfConsumer$1.invoke(CxfConsumer.java=
:85)
>>>>>> =A0 at
>>>>>> org.apache.cxf.interceptor.ServiceInvokerInterceptor$1.run(ServiceIn=
vokerInterceptor.java:57)
>>>>>> =A0 at
>>>>>> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:4=
41)
>>>>>> =A0 at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java=
:303)
>>>>>> =A0 at java.util.concurrent.FutureTask.run(FutureTask.java:138)
>>>>>> =A0 at
>>>>>> org.apache.cxf.workqueue.SynchronousExecutor.execute(SynchronousExec=
utor.java:37)
>>>>>> =A0 at
>>>>>> org.apache.cxf.interceptor.ServiceInvokerInterceptor.handleMessage(S=
erviceInvokerInterceptor.java:95)
>>>>>> =A0 at
>>>>>> org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseIntercep=
torChain.java:236)
>>>>>> =A0 at
>>>>>> org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInit=
iationObserver.java:89)
>>>>>> =A0 at
>>>>>> org.apache.cxf.transport.http_jetty.JettyHTTPDestination.serviceRequ=
est(JettyHTTPDestination.java:302)
>>>>>> =A0 at
>>>>>> org.apache.cxf.transport.http_jetty.JettyHTTPDestination.doService(J=
ettyHTTPDestination.java:265)
>>>>>> =A0 at
>>>>>> org.apache.cxf.transport.http_jetty.JettyHTTPHandler.handle(JettyHTT=
PHandler.java:70)
>>>>>> =A0 at
>>>>>> org.mortbay.jetty.handler.ContextHandler.handle(ContextHandler.java:=
766)
>>>>>> =A0 at
>>>>>> org.mortbay.jetty.handler.ContextHandlerCollection.handle(ContextHan=
dlerCollection.java:230)
>>>>>> =A0 at
>>>>>> org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:=
152)
>>>>>> =A0 at org.mortbay.jetty.Server.handle(Server.java:324)
>>>>>> =A0 at
>>>>>> org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:5=
34)
>>>>>> =A0 at
>>>>>> org.mortbay.jetty.HttpConnection$RequestHandler.content(HttpConnecti=
on.java:879)
>>>>>> =A0 at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:741)
>>>>>> =A0 at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:2=
13)
>>>>>> =A0 at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:4=
03)
>>>>>> =A0 at
>>>>>> org.mortbay.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.j=
ava:409)
>>>>>> =A0 at
>>>>>> org.mortbay.thread.QueuedThreadPool$PoolThread.run(QueuedThreadPool.=
java:522)
>>>>>>
>>>>>>
>>>>>> Where is the problem ?
>>>>>>
>>>>>> Regards,
>>>>>>
>>>>>>
>>>>>>
>>>>>
>>>>> -----
>>>>> Charles Moulliard
>>>>> SOA Architect
>>>>>
>>>>> My Blog : =A0http://cmoulliard.blogspot.com/
>>>>> http://cmoulliard.blogspot.com/
>>>>
>>>>
>>>
>>>
>>> -----
>>> Charles Moulliard
>>> SOA Architect
>>>
>>> My Blog : =A0http://cmoulliard.blogspot.com/
>>> http://cmoulliard.blogspot.com/
>>
>>
>>
>
>
> -----
> Charles Moulliard
> SOA Architect
>
> My Blog : =A0http://cmoulliard.blogspot.com/ http://cmoulliard.blogspot.c=
om/
> --
> View this message in context: http://www.nabble.com/Camel-2.0---Multicast=
-issue----tp22725597p22738110.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
>



--=20
Claus Ibsen
Apache Camel Committer

Open Source Integration: http://fusesource.com
Blog: http://davsclaus.blogspot.com/
Twitter: http://twitter.com/davsclaus