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 <[email protected]>: > > 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 waited > by the calling process > > e.g. > > <from uri=""> > ... > <!-- at this point we don't wait any OUT message from endpoints called, our > strategy is pure > FIRE/FORGET --> > <parallel> > <to uri="direct:feedbackWS"/> > <to uri="direct:saveWS"/> > </parrallel> > > An extension of this could be that parallel does not receive OUT message but > properties or headers like e.g. parallelName="feedbackWS", > status="processed" and we could provide a timer as a property. > > <parallel timer="180" feedbackRequested="true"> > ... > </parallel> > > If one of the parallel process does not finish until the period defined by > 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 AggregationStrategy >> { >> // only return the exchage which has the out message >> public Exchange aggregate(Exchange oldExchange, Exchange newExchange) >> { >> if (oldExchange.getOutMessage(false)!= null) { >> return oldExchange; >> } else { >> return newExchange; >> } >> } >> } >> >> Willem >> >> >> >> cmoulliard wrote: >>> Many thanks Willem. In fact, I tried to use the multicast as a workaround >>> 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 the >>> same message to two different endpoints (direct:feedbackWS and >>> direct:saveWS). >>> >>> Nevertheless, I will try to adapt my multicast routes as you propose (put >>> 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 configuration >>>> 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 LoanBroker >>>> Example[1] of Camel. >>>> >>>> [1]http://cwiki.apache.org/CAMEL/loan-broker-example.html#LoanBrokerExample-Implementationwithwebservice >>>> >>>> Willem >>>> >>>> >>>> >>>> cmoulliard wrote: >>>>> To solve the error returned and as proposed by Claus, I have modified >>>>> my >>>>> route like this >>>>> >>>>> <camel:inOnly uri="queuingservice:queue:in" /> >>>>> >>>>> Nevertheless, the multicast does not work as we can in the log here : >>>>> >>>>> 17:38:34,250 | INFO | 25328...@qtp2-0 | TraceInterceptor >>>>> | >>>>> rg.apache.camel.processor.Logger 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=[BindingOperationInfo: >>>>> {http://reportincident.example.camel.apache.org}ReportIncident], >>>>> CamelCXFDataFormat=POJO}, Headers:{content-type=text/xml;charset=UTF-8, >>>>> content.type=text/xml;charset=UTF-8, operationName=ReportIncident, >>>>> Host=localhost:8080, Content-Length=640, >>>>> SOAPAction="http://reportincident.example.camel.apache.org/ReportIncident";, >>>>> User-Agent=Jakarta Commons-HttpClient/3.1, >>>>> org.apache.cxf.headers.Header.list=[], >>>>> operationNameSpace=http://reportincident.example.camel.apache.org}, >>>>> BodyType:org.apache.cxf.message.MessageContentsList, >>>>> Body:[org.apache.camel.example.reportincident.inputreportincid...@250f55] >>>>> 17:38:34,265 | INFO | 25328...@qtp2-0 | TraceInterceptor >>>>> | >>>>> rg.apache.camel.processor.Logger 88 | >>>>> ID-dell-charles-1751-1238084114250-2-7 >>> setHeader(webservice) --> >>>>> convertBodyTo(), Pattern:InOut, >>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=[BindingOperationInfo: >>>>> {http://reportincident.example.camel.apache.org}ReportIncident], >>>>> CamelCXFDataFormat=POJO}, Headers:{content-type=text/xml;charset=UTF-8, >>>>> operationName=ReportIncident, content.type=text/xml;charset=UTF-8, >>>>> Host=localhost:8080, Content-Length=640, >>>>> SOAPAction="http://reportincident.example.camel.apache.org/ReportIncident";, >>>>> origin=webservice, User-Agent=Jakarta Commons-HttpClient/3.1, >>>>> operationNameSpace=http://reportincident.example.camel.apache.org, >>>>> org.apache.cxf.headers.Header.list=[]}, >>>>> BodyType:org.apache.cxf.message.MessageContentsList, >>>>> Body:[org.apache.camel.example.reportincident.inputreportincid...@250f55] >>>>> 17:38:34,265 | INFO | 25328...@qtp2-0 | TraceInterceptor >>>>> | >>>>> rg.apache.camel.processor.Logger 88 | >>>>> ID-dell-charles-1751-1238084114250-2-7 >>> convertBodyTo() --> >>>>> multicast(), >>>>> Pattern:InOut, >>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=[BindingOperationInfo: >>>>> {http://reportincident.example.camel.apache.org}ReportIncident], >>>>> CamelCXFDataFormat=POJO}, Headers:{content-type=text/xml;charset=UTF-8, >>>>> operationName=ReportIncident, content.type=text/xml;charset=UTF-8, >>>>> Host=localhost:8080, Content-Length=640, >>>>> SOAPAction="http://reportincident.example.camel.apache.org/ReportIncident";, >>>>> origin=webservice, User-Agent=Jakarta Commons-HttpClient/3.1, >>>>> operationNameSpace=http://reportincident.example.camel.apache.org, >>>>> org.apache.cxf.headers.Header.list=[]}, >>>>> BodyType:org.apache.camel.example.reportincident.InputReportIncident, >>>>> Body:org.apache.camel.example.reportincident.inputreportincid...@250f55 >>>>> 17:38:34,265 | INFO | 25328...@qtp2-0 | TraceInterceptor >>>>> | >>>>> rg.apache.camel.processor.Logger 88 | >>>>> ID-dell-charles-1751-1238084114250-2-7 >>> multicast() --> >>>>> to(direct:feedbackWS), Pattern:InOut, >>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=[BindingOperationInfo: >>>>> {http://reportincident.example.camel.apache.org}ReportIncident], >>>>> CamelCXFDataFormat=POJO}, Headers:{content-type=text/xml;charset=UTF-8, >>>>> content.type=text/xml;charset=UTF-8, operationName=ReportIncident, >>>>> Host=localhost:8080, Content-Length=640, origin=webservice, >>>>> SOAPAction="http://reportincident.example.camel.apache.org/ReportIncident";, >>>>> User-Agent=Jakarta Commons-HttpClient/3.1, >>>>> org.apache.cxf.headers.Header.list=[], >>>>> operationNameSpace=http://reportincident.example.camel.apache.org}, >>>>> BodyType:org.apache.camel.example.reportincident.InputReportIncident, >>>>> Body:org.apache.camel.example.reportincident.inputreportincid...@250f55 >>>>> 17:38:34,281 | INFO | 25328...@qtp2-0 | TraceInterceptor >>>>> | >>>>> rg.apache.camel.processor.Logger 88 | >>>>> ID-dell-charles-1751-1238084114250-2-7 >>> to(direct:feedbackWS) --> >>>>> transform(), Pattern:InOut, >>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=[BindingOperationInfo: >>>>> {http://reportincident.example.camel.apache.org}ReportIncident], >>>>> CamelCXFDataFormat=POJO}, Headers:{content-type=text/xml;charset=UTF-8, >>>>> content.type=text/xml;charset=UTF-8, operationName=ReportIncident, >>>>> Host=localhost:8080, Content-Length=640, origin=webservice, >>>>> SOAPAction="http://reportincident.example.camel.apache.org/ReportIncident";, >>>>> User-Agent=Jakarta Commons-HttpClient/3.1, >>>>> org.apache.cxf.headers.Header.list=[], >>>>> operationNameSpace=http://reportincident.example.camel.apache.org}, >>>>> BodyType:org.apache.camel.example.reportincident.InputReportIncident, >>>>> Body:org.apache.camel.example.reportincident.inputreportincid...@250f55 >>>>> 17:38:34,281 | INFO | 25328...@qtp2-0 | TraceInterceptor >>>>> | >>>>> rg.apache.camel.processor.Logger 88 | >>>>> ID-dell-charles-1751-1238084114250-2-7 >>> transform() --> >>>>> to(direct:saveWS), Pattern:InOut, >>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=[BindingOperationInfo: >>>>> {http://reportincident.example.camel.apache.org}ReportIncident], >>>>> CamelCXFDataFormat=POJO}, Headers:{content-type=text/xml;charset=UTF-8, >>>>> content.type=text/xml;charset=UTF-8, operationName=ReportIncident, >>>>> Host=localhost:8080, Content-Length=640, origin=webservice, >>>>> SOAPAction="http://reportincident.example.camel.apache.org/ReportIncident";, >>>>> User-Agent=Jakarta Commons-HttpClient/3.1, >>>>> org.apache.cxf.headers.Header.list=[], >>>>> operationNameSpace=http://reportincident.example.camel.apache.org}, >>>>> BodyType:org.apache.camel.example.reportincident.InputReportIncident, >>>>> Body:org.apache.camel.example.reportincident.inputreportincid...@250f55 >>>>> 17:38:34,296 | INFO | 25328...@qtp2-0 | TraceInterceptor >>>>> | >>>>> rg.apache.camel.processor.Logger 88 | >>>>> ID-dell-charles-1751-1238084114250-2-7 >>> to(direct:saveWS) --> >>>>> to(bean:webservice), Pattern:InOut, >>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=[BindingOperationInfo: >>>>> {http://reportincident.example.camel.apache.org}ReportIncident], >>>>> CamelCXFDataFormat=POJO}, Headers:{content-type=text/xml;charset=UTF-8, >>>>> content.type=text/xml;charset=UTF-8, operationName=ReportIncident, >>>>> Host=localhost:8080, Content-Length=640, origin=webservice, >>>>> SOAPAction="http://reportincident.example.camel.apache.org/ReportIncident";, >>>>> User-Agent=Jakarta Commons-HttpClient/3.1, >>>>> org.apache.cxf.headers.Header.list=[], >>>>> operationNameSpace=http://reportincident.example.camel.apache.org}, >>>>> BodyType:org.apache.camel.example.reportincident.InputReportIncident, >>>>> Body:org.apache.camel.example.reportincident.inputreportincid...@250f55 >>>>> 17:38:34,312 | INFO | 25328...@qtp2-0 | TraceInterceptor >>>>> | >>>>> rg.apache.camel.processor.Logger 88 | >>>>> ID-dell-charles-1751-1238084114250-2-7 >>> to(bean:webservice) --> >>>>> inOnly(queuingservice:queue:in), Pattern:InOut, >>>>> Properties:{CamelBeanHolder=bean: webservice, >>>>> org.apache.cxf.service.model.BindingOperationInfo=[BindingOperationInfo: >>>>> {http://reportincident.example.camel.apache.org}ReportIncident], >>>>> CamelCXFDataFormat=POJO}, BodyType:java.util.ArrayList, >>>>> Body:[{org.apache.camel.example.reportincident.model.incident=org.apache.camel.example.reportincident.model.incid...@e22502[ >>>>> incidentId=0 >>>>> incidentRef=20 >>>>> incidentDate=<null> >>>>> givenName=Charles >>>>> familyName=Moulliard >>>>> summary=This is an OSGI report incident >>>>> details=nothing to say >>>>> [email protected] >>>>> phone=+352 25 10 70 470 >>>>> creationUser=<null> >>>>> creationDate=<null> >>>>> ]}] >>>>> 17:38:34,343 | INFO | ActiveMQ Task | FailoverTransport >>>>> | >>>>> sport.failover.FailoverTransport 714 | Successfully connected to >>>>> tcp://localhost:61616 >>>>> 17:38:34,437 | INFO | enerContainer-35 | TraceInterceptor >>>>> | >>>>> rg.apache.camel.processor.Logger 88 | >>>>> ID-dell-charles-1751-1238084114250-2-8 >>> queuingservice:queue:in --> >>>>> to(bean:incidentSaver?method=process), Pattern:InOnly, >>>>> Headers:{JMSXGroupID=null, JMSCorrelationID=null, JMSType=null, >>>>> JMSExpiration=0, >>>>> JMSMessageID=ID:dell-charles-1712-1238084102453-2:3:1:1:1, >>>>> JMSRedelivered=false, JMSDeliveryMode=2, JMSPriority=4, >>>>> JMSReplyTo=null, >>>>> JMSTimestamp=1238085514359, JMSDestination=queue://in}, >>>>> BodyType:java.util.ArrayList, >>>>> Body:[{org.apache.camel.example.reportincident.model.incident=org.apache.camel.example.reportincident.model.incid...@f0bca1[ >>>>> incidentId=0 >>>>> incidentRef=20 >>>>> incidentDate=<null> >>>>> givenName=Charles >>>>> familyName=Moulliard >>>>> summary=This is an OSGI report incident >>>>> details=nothing to say >>>>> [email protected] >>>>> phone=+352 25 10 70 470 >>>>> creationUser=<null> >>>>> creationDate=<null> >>>>> ]}] >>>>> 17:38:34,421 | INFO | 25328...@qtp2-0 | PhaseInterceptorChain >>>>> | >>>>> ransport.ChainInitiationObserver 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. >>>>> at >>>>> org.apache.cxf.jaxb.JAXBEncoderDecoder.marshall(JAXBEncoderDecoder.java:159) >>>>> at >>>>> org.apache.cxf.jaxb.io.DataWriterImpl.write(DataWriterImpl.java:169) >>>>> at >>>>> org.apache.cxf.interceptor.AbstractOutDatabindingInterceptor.writeParts(AbstractOutDatabindingInterceptor.java:104) >>>>> at >>>>> org.apache.cxf.interceptor.BareOutInterceptor.handleMessage(BareOutInterceptor.java:68) >>>>> at >>>>> org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:236) >>>>> at >>>>> org.apache.cxf.interceptor.OutgoingChainInterceptor.handleMessage(OutgoingChainInterceptor.java:74) >>>>> at >>>>> org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:236) >>>>> at >>>>> org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInitiationObserver.java:89) >>>>> at >>>>> org.apache.cxf.transport.http_jetty.JettyHTTPDestination.serviceRequest(JettyHTTPDestination.java:302) >>>>> at >>>>> org.apache.cxf.transport.http_jetty.JettyHTTPDestination.doService(JettyHTTPDestination.java:265) >>>>> at >>>>> org.apache.cxf.transport.http_jetty.JettyHTTPHandler.handle(JettyHTTPHandler.java:70) >>>>> at >>>>> org.mortbay.jetty.handler.ContextHandler.handle(ContextHandler.java:766) >>>>> at >>>>> org.mortbay.jetty.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:230) >>>>> at >>>>> org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:152) >>>>> at org.mortbay.jetty.Server.handle(Server.java:324) >>>>> at >>>>> org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:534) >>>>> at >>>>> org.mortbay.jetty.HttpConnection$RequestHandler.content(HttpConnection.java:879) >>>>> at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:741) >>>>> at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:213) >>>>> at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:403) >>>>> at >>>>> org.mortbay.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.java:409) >>>>> at >>>>> org.mortbay.thread.QueuedThreadPool$PoolThread.run(QueuedThreadPool.java:522) >>>>> Caused by: javax.xml.bind.MarshalException >>>>> - with linked exception: >>>>> [javax.xml.bind.JAXBException: class java.util.HashMap nor any of its >>>>> super >>>>> class is known to this context.] >>>>> at >>>>> com.sun.xml.bind.v2.runtime.MarshallerImpl.write(MarshallerImpl.java:331) >>>>> at >>>>> com.sun.xml.bind.v2.runtime.MarshallerImpl.marshal(MarshallerImpl.java:257) >>>>> at >>>>> javax.xml.bind.helpers.AbstractMarshallerImpl.marshal(AbstractMarshallerImpl.java:100) >>>>> at >>>>> org.apache.cxf.jaxb.JAXBEncoderDecoder.writeObject(JAXBEncoderDecoder.java:441) >>>>> at >>>>> org.apache.cxf.jaxb.JAXBEncoderDecoder.marshall(JAXBEncoderDecoder.java:138) >>>>> ... 21 more >>>>> Caused by: javax.xml.bind.JAXBException: class java.util.HashMap nor >>>>> any >>>>> of >>>>> its super class is known to this context. >>>>> at >>>>> com.sun.xml.bind.v2.runtime.XMLSerializer.reportError(XMLSerializer.java:242) >>>>> at >>>>> com.sun.xml.bind.v2.runtime.XMLSerializer.reportError(XMLSerializer.java:257) >>>>> at >>>>> com.sun.xml.bind.v2.runtime.XMLSerializer.childAsXsiType(XMLSerializer.java:649) >>>>> at >>>>> com.sun.xml.bind.v2.runtime.property.SingleElementNodeProperty.serializeBody(SingleElementNodeProperty.java:147) >>>>> at >>>>> com.sun.xml.bind.v2.runtime.ElementBeanInfoImpl$1.serializeBody(ElementBeanInfoImpl.java:156) >>>>> at >>>>> com.sun.xml.bind.v2.runtime.ElementBeanInfoImpl$1.serializeBody(ElementBeanInfoImpl.java:185) >>>>> at >>>>> com.sun.xml.bind.v2.runtime.ElementBeanInfoImpl.serializeBody(ElementBeanInfoImpl.java:305) >>>>> at >>>>> com.sun.xml.bind.v2.runtime.ElementBeanInfoImpl.serializeRoot(ElementBeanInfoImpl.java:312) >>>>> at >>>>> com.sun.xml.bind.v2.runtime.ElementBeanInfoImpl.serializeRoot(ElementBeanInfoImpl.java:71) >>>>> at >>>>> com.sun.xml.bind.v2.runtime.XMLSerializer.childAsRoot(XMLSerializer.java:490) >>>>> at >>>>> com.sun.xml.bind.v2.runtime.MarshallerImpl.write(MarshallerImpl.java:328) >>>>> ... 25 more >>>>> Caused by: javax.xml.bind.JAXBException: class java.util.HashMap nor >>>>> any >>>>> of >>>>> its super class is known to this context. >>>>> at >>>>> com.sun.xml.bind.v2.runtime.JAXBContextImpl.getBeanInfo(JAXBContextImpl.java:556) >>>>> at >>>>> com.sun.xml.bind.v2.runtime.XMLSerializer.childAsXsiType(XMLSerializer.java:644) >>>>> ... 33 more >>>>> >>>>> cmoulliard wrote: >>>>>> Hi, >>>>>> >>>>>> I have defined the following routes in camel : >>>>>> >>>>>> <!-- Receive WS message, multicast the message and provive >>>>>> feedback >>>>>> --> >>>>>> <camel:route> >>>>>> <camel:from uri="cxf:bean:reportIncident" /> >>>>>> <!-- issue resolved 26/03/2009 --> >>>>>> <camel:setHeader headerName="origin"> >>>>>> <camel:constant>webservice</camel:constant> >>>>>> </camel:setHeader> >>>>>> <camel:convertBodyTo >>>>>> type="org.apache.camel.example.reportincident.InputReportIncident" /> >>>>>> <camel:multicast> >>>>>> <camel:to uri="direct:feedbackWS"/> >>>>>> <camel:to uri="direct:saveWS"/> >>>>>> </camel:multicast> >>>>>> </camel:route> >>>>>> >>>>>> <!-- Send feedback to WebService --> >>>>>> <camel:route> >>>>>> <camel:from uri="direct:feedbackWS" /> >>>>>> <camel:transform> >>>>>> <camel:method bean="feedback" method="setOk" /> >>>>>> </camel:transform> >>>>>> </camel:route> >>>>>> >>>>>> <!-- Convert WS message and put it in the queue --> >>>>>> <camel:route> >>>>>> <camel:from uri="direct:saveWS" /> >>>>>> <camel:to uri="bean:webservice" /> >>>>>> <camel:to uri="queuingservice:queue:in" /> >>>>>> </camel:route> >>>>>> >>>>>> When calling the web service, we can see in the trace that the process >>>>>> starts correctly but the multicast seems to mix the routes and a error >>>>>> is >>>>>> generated : >>>>>> >>>>>> 17:16:08,562 | INFO | 12773...@qtp1-0 | TraceInterceptor >>>>>> | rg.apache.camel.processor.Logger 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=[BindingOperationInfo: >>>>>> {http://reportincident.example.camel.apache.org}ReportIncident], >>>>>> CamelCXFDataFormat=POJO}, >>>>>> Headers:{content-type=text/xml;charset=UTF-8, >>>>>> content.type=text/xml;charset=UTF-8, operationName=ReportIncident, >>>>>> Host=localhost:8080, Content-Length=640, >>>>>> SOAPAction="http://reportincident.example.camel.apache.org/ReportIncident";, >>>>>> User-Agent=Jakarta Commons-HttpClient/3.1, >>>>>> org.apache.cxf.headers.Header.list=[], >>>>>> operationNameSpace=http://reportincident.example.camel.apache.org}, >>>>>> BodyType:org.apache.cxf.message.MessageContentsList, >>>>>> Body:[org.apache.camel.example.reportincident.inputreportincid...@ea9f6e] >>>>>> >>>>>> 17:16:08,578 | INFO | 12773...@qtp1-0 | TraceInterceptor >>>>>> | rg.apache.camel.processor.Logger 88 | >>>>>> ID-dell-charles-1751-1238084114250-2-0 >>> setHeader(webservice) --> >>>>>> convertBodyTo(), Pattern:InOut, >>>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=[BindingOperationInfo: >>>>>> {http://reportincident.example.camel.apache.org}ReportIncident], >>>>>> CamelCXFDataFormat=POJO}, >>>>>> Headers:{content-type=text/xml;charset=UTF-8, >>>>>> operationName=ReportIncident, content.type=text/xml;charset=UTF-8, >>>>>> Host=localhost:8080, Content-Length=640, >>>>>> SOAPAction="http://reportincident.example.camel.apache.org/ReportIncident";, >>>>>> origin=webservice, User-Agent=Jakarta Commons-HttpClient/3.1, >>>>>> operationNameSpace=http://reportincident.example.camel.apache.org, >>>>>> org.apache.cxf.headers.Header.list=[]}, >>>>>> BodyType:org.apache.cxf.message.MessageContentsList, >>>>>> Body:[org.apache.camel.example.reportincident.inputreportincid...@ea9f6e] >>>>>> >>>>>> 17:16:08,578 | INFO | 12773...@qtp1-0 | TraceInterceptor >>>>>> | rg.apache.camel.processor.Logger 88 | >>>>>> ID-dell-charles-1751-1238084114250-2-0 >>> convertBodyTo() --> >>>>>> multicast(), Pattern:InOut, >>>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=[BindingOperationInfo: >>>>>> {http://reportincident.example.camel.apache.org}ReportIncident], >>>>>> CamelCXFDataFormat=POJO}, >>>>>> Headers:{content-type=text/xml;charset=UTF-8, >>>>>> operationName=ReportIncident, content.type=text/xml;charset=UTF-8, >>>>>> Host=localhost:8080, Content-Length=640, >>>>>> SOAPAction="http://reportincident.example.camel.apache.org/ReportIncident";, >>>>>> origin=webservice, User-Agent=Jakarta Commons-HttpClient/3.1, >>>>>> operationNameSpace=http://reportincident.example.camel.apache.org, >>>>>> org.apache.cxf.headers.Header.list=[]}, >>>>>> BodyType:org.apache.camel.example.reportincident.InputReportIncident, >>>>>> Body:org.apache.camel.example.reportincident.inputreportincid...@ea9f6e >>>>>> >>>>>> 17:16:08,593 | INFO | 12773...@qtp1-0 | TraceInterceptor >>>>>> | rg.apache.camel.processor.Logger 88 | >>>>>> ID-dell-charles-1751-1238084114250-2-0 >>> multicast() --> >>>>>> to(direct:feedbackWS), Pattern:InOut, >>>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=[BindingOperationInfo: >>>>>> {http://reportincident.example.camel.apache.org}ReportIncident], >>>>>> CamelCXFDataFormat=POJO}, >>>>>> Headers:{content-type=text/xml;charset=UTF-8, >>>>>> content.type=text/xml;charset=UTF-8, operationName=ReportIncident, >>>>>> Host=localhost:8080, Content-Length=640, origin=webservice, >>>>>> SOAPAction="http://reportincident.example.camel.apache.org/ReportIncident";, >>>>>> User-Agent=Jakarta Commons-HttpClient/3.1, >>>>>> org.apache.cxf.headers.Header.list=[], >>>>>> operationNameSpace=http://reportincident.example.camel.apache.org}, >>>>>> BodyType:org.apache.camel.example.reportincident.InputReportIncident, >>>>>> Body:org.apache.camel.example.reportincident.inputreportincid...@ea9f6e >>>>>> >>>>>> 17:16:08,593 | INFO | 12773...@qtp1-0 | TraceInterceptor >>>>>> | rg.apache.camel.processor.Logger 88 | >>>>>> ID-dell-charles-1751-1238084114250-2-0 >>> to(direct:feedbackWS) --> >>>>>> transform(), Pattern:InOut, >>>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=[BindingOperationInfo: >>>>>> {http://reportincident.example.camel.apache.org}ReportIncident], >>>>>> CamelCXFDataFormat=POJO}, >>>>>> Headers:{content-type=text/xml;charset=UTF-8, >>>>>> content.type=text/xml;charset=UTF-8, operationName=ReportIncident, >>>>>> Host=localhost:8080, Content-Length=640, origin=webservice, >>>>>> SOAPAction="http://reportincident.example.camel.apache.org/ReportIncident";, >>>>>> User-Agent=Jakarta Commons-HttpClient/3.1, >>>>>> org.apache.cxf.headers.Header.list=[], >>>>>> operationNameSpace=http://reportincident.example.camel.apache.org}, >>>>>> BodyType:org.apache.camel.example.reportincident.InputReportIncident, >>>>>> Body:org.apache.camel.example.reportincident.inputreportincid...@ea9f6e >>>>>> >>>>>> 17:16:08,625 | INFO | 12773...@qtp1-0 | TraceInterceptor >>>>>> | rg.apache.camel.processor.Logger 88 | >>>>>> ID-dell-charles-1751-1238084114250-2-0 >>> transform() --> >>>>>> to(direct:saveWS), Pattern:InOut, >>>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=[BindingOperationInfo: >>>>>> {http://reportincident.example.camel.apache.org}ReportIncident], >>>>>> CamelCXFDataFormat=POJO}, >>>>>> Headers:{content-type=text/xml;charset=UTF-8, >>>>>> content.type=text/xml;charset=UTF-8, operationName=ReportIncident, >>>>>> Host=localhost:8080, Content-Length=640, origin=webservice, >>>>>> SOAPAction="http://reportincident.example.camel.apache.org/ReportIncident";, >>>>>> User-Agent=Jakarta Commons-HttpClient/3.1, >>>>>> org.apache.cxf.headers.Header.list=[], >>>>>> operationNameSpace=http://reportincident.example.camel.apache.org}, >>>>>> BodyType:org.apache.camel.example.reportincident.InputReportIncident, >>>>>> Body:org.apache.camel.example.reportincident.inputreportincid...@ea9f6e >>>>>> >>>>>> 17:16:08,640 | INFO | 12773...@qtp1-0 | TraceInterceptor >>>>>> | rg.apache.camel.processor.Logger 88 | >>>>>> ID-dell-charles-1751-1238084114250-2-0 >>> to(direct:saveWS) --> >>>>>> to(bean:webservice), Pattern:InOut, >>>>>> Properties:{org.apache.cxf.service.model.BindingOperationInfo=[BindingOperationInfo: >>>>>> {http://reportincident.example.camel.apache.org}ReportIncident], >>>>>> CamelCXFDataFormat=POJO}, >>>>>> Headers:{content-type=text/xml;charset=UTF-8, >>>>>> content.type=text/xml;charset=UTF-8, operationName=ReportIncident, >>>>>> Host=localhost:8080, Content-Length=640, origin=webservice, >>>>>> SOAPAction="http://reportincident.example.camel.apache.org/ReportIncident";, >>>>>> User-Agent=Jakarta Commons-HttpClient/3.1, >>>>>> org.apache.cxf.headers.Header.list=[], >>>>>> operationNameSpace=http://reportincident.example.camel.apache.org}, >>>>>> BodyType:org.apache.camel.example.reportincident.InputReportIncident, >>>>>> Body:org.apache.camel.example.reportincident.inputreportincid...@ea9f6e >>>>>> >>>>>> 17:16:08,671 | INFO | 12773...@qtp1-0 | TraceInterceptor >>>>>> | rg.apache.camel.processor.Logger 88 | >>>>>> ID-dell-charles-1751-1238084114250-2-0 >>> to(bean:webservice) --> >>>>>> to(queuingservice:queue:in), Pattern:InOut, >>>>>> Properties:{CamelBeanHolder=bean: webservice, >>>>>> org.apache.cxf.service.model.BindingOperationInfo=[BindingOperationInfo: >>>>>> {http://reportincident.example.camel.apache.org}ReportIncident], >>>>>> CamelCXFDataFormat=POJO}, BodyType:java.util.ArrayList, >>>>>> Body:[{org.apache.camel.example.reportincident.model.incident=org.apache.camel.example.reportincident.model.incid...@14bbd50[ >>>>>> incidentId=0 >>>>>> incidentRef=20 >>>>>> incidentDate=<null> >>>>>> givenName=Charles >>>>>> familyName=Moulliard >>>>>> summary=This is an OSGI report incident >>>>>> details=nothing to say >>>>>> [email protected] >>>>>> phone=+352 25 10 70 470 >>>>>> creationUser=<null> >>>>>> creationDate=<null> >>>>>> ]}] >>>>>> 17:16:08,750 | INFO | ActiveMQ Task | FailoverTransport >>>>>> | sport.failover.FailoverTransport 714 | Successfully connected to >>>>>> tcp://localhost:61616 >>>>>> 17:16:09,046 | INFO | enerContainer-55 | TraceInterceptor >>>>>> | rg.apache.camel.processor.Logger 88 | >>>>>> ID-dell-charles-1751-1238084114250-2-1 >>> queuingservice:queue:in --> >>>>>> to(bean:incidentSaver?method=process), Pattern:InOut, >>>>>> Properties:{JMSReplyTo=temp-queue://ID:dell-charles-1712-1238084102453-2:1:1}, >>>>>> Headers:{JMSXGroupID=null, >>>>>> JMSCorrelationID=ID-dell-charles-1751-1238084114250-3-0, JMSType=null, >>>>>> JMSExpiration=1238084188953, >>>>>> JMSMessageID=ID:dell-charles-1712-1238084102453-2:1:2:1:1, >>>>>> JMSRedelivered=false, JMSDeliveryMode=2, JMSPriority=4, >>>>>> JMSReplyTo=temp-queue://ID:dell-charles-1712-1238084102453-2:1:1, >>>>>> JMSTimestamp=1238084168953, JMSDestination=queue://in}, >>>>>> BodyType:java.util.ArrayList, >>>>>> Body:[{org.apache.camel.example.reportincident.model.incident=org.apache.camel.example.reportincident.model.incid...@127d19d[ >>>>>> incidentId=0 >>>>>> incidentRef=20 >>>>>> incidentDate=<null> >>>>>> givenName=Charles >>>>>> familyName=Moulliard >>>>>> summary=This is an OSGI report incident >>>>>> details=nothing to say >>>>>> [email protected] >>>>>> phone=+352 25 10 70 470 >>>>>> creationUser=<null> >>>>>> creationDate=<null> >>>>>> ]}] >>>>>> 17:16:31,250 | ERROR | 12773...@qtp1-0 | DeadLetterChannel >>>>>> | rg.apache.camel.processor.Logger 207 | Failed delivery for >>>>>> exchangeId: >>>>>> ID-dell-charles-1751-1238084114250-0-1. On delivery attempt: 0 caught: >>>>>> 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=org.apache.camel.example.reportincident.model.incid...@14bbd50[ >>>>>> incidentId=0 >>>>>> incidentRef=20 >>>>>> incidentDate=<null> >>>>>> givenName=Charles >>>>>> familyName=Moulliard >>>>>> summary=This is an OSGI report incident >>>>>> details=nothing to say >>>>>> [email protected] >>>>>> phone=+352 25 10 70 470 >>>>>> creationUser=<null> >>>>>> creationDate=<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=org.apache.camel.example.reportincident.model.incid...@14bbd50[ >>>>>> incidentId=0 >>>>>> incidentRef=20 >>>>>> incidentDate=<null> >>>>>> givenName=Charles >>>>>> familyName=Moulliard >>>>>> summary=This is an OSGI report incident >>>>>> details=nothing to say >>>>>> [email protected] >>>>>> phone=+352 25 10 70 470 >>>>>> creationUser=<null> >>>>>> creationDate=<null> >>>>>> ]}]] >>>>>> at >>>>>> org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:269) >>>>>> at >>>>>> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:69) >>>>>> at >>>>>> org.apache.camel.processor.DelegateProcessor.processNext(DelegateProcessor.java:49) >>>>>> at >>>>>> org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcessor.java:78) >>>>>> at >>>>>> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:115) >>>>>> at >>>>>> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:80) >>>>>> at >>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.proceed(StreamCachingInterceptor.java:83) >>>>>> at >>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.process(StreamCachingInterceptor.java:78) >>>>>> at >>>>>> org.apache.camel.processor.DeadLetterChannel.process(DeadLetterChannel.java:204) >>>>>> at >>>>>> org.apache.camel.processor.DeadLetterChannel.process(DeadLetterChannel.java:145) >>>>>> at org.apache.camel.processor.Pipeline.process(Pipeline.java:115) >>>>>> at org.apache.camel.processor.Pipeline.process(Pipeline.java:89) >>>>>> at >>>>>> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68) >>>>>> at >>>>>> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:41) >>>>>> at >>>>>> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:55) >>>>>> at >>>>>> org.apache.camel.processor.DelegateProcessor.processNext(DelegateProcessor.java:49) >>>>>> at >>>>>> org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcessor.java:78) >>>>>> at >>>>>> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:115) >>>>>> at >>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.proceed(StreamCachingInterceptor.java:86) >>>>>> at >>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.process(StreamCachingInterceptor.java:78) >>>>>> at >>>>>> org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:70) >>>>>> at >>>>>> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:41) >>>>>> at >>>>>> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:65) >>>>>> at >>>>>> org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:47) >>>>>> at >>>>>> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:69) >>>>>> at >>>>>> org.apache.camel.processor.DelegateProcessor.processNext(DelegateProcessor.java:49) >>>>>> at >>>>>> org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcessor.java:78) >>>>>> at >>>>>> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:115) >>>>>> at >>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.proceed(StreamCachingInterceptor.java:86) >>>>>> at >>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.process(StreamCachingInterceptor.java:78) >>>>>> at >>>>>> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:41) >>>>>> at >>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.process(StreamCachingInterceptor.java:68) >>>>>> at >>>>>> org.apache.camel.processor.MulticastProcessor.process(MulticastProcessor.java:191) >>>>>> at >>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.proceed(StreamCachingInterceptor.java:86) >>>>>> at >>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.process(StreamCachingInterceptor.java:78) >>>>>> at >>>>>> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:41) >>>>>> at >>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.process(StreamCachingInterceptor.java:68) >>>>>> at >>>>>> org.apache.camel.processor.DelegateProcessor.processNext(DelegateProcessor.java:49) >>>>>> at >>>>>> org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcessor.java:78) >>>>>> at >>>>>> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:115) >>>>>> at >>>>>> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:80) >>>>>> at >>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.proceed(StreamCachingInterceptor.java:83) >>>>>> at >>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.process(StreamCachingInterceptor.java:78) >>>>>> at >>>>>> org.apache.camel.processor.DeadLetterChannel.process(DeadLetterChannel.java:204) >>>>>> at >>>>>> org.apache.camel.processor.DeadLetterChannel.process(DeadLetterChannel.java:145) >>>>>> at org.apache.camel.processor.Pipeline.process(Pipeline.java:115) >>>>>> at org.apache.camel.processor.Pipeline.process(Pipeline.java:89) >>>>>> at >>>>>> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:68) >>>>>> at >>>>>> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:41) >>>>>> at >>>>>> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:55) >>>>>> at >>>>>> org.apache.camel.processor.DelegateProcessor.processNext(DelegateProcessor.java:49) >>>>>> at >>>>>> org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcessor.java:78) >>>>>> at >>>>>> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:115) >>>>>> at >>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.proceed(StreamCachingInterceptor.java:86) >>>>>> at >>>>>> org.apache.camel.processor.interceptor.StreamCachingInterceptor.process(StreamCachingInterceptor.java:78) >>>>>> at >>>>>> org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:52) >>>>>> at >>>>>> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:41) >>>>>> at >>>>>> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:65) >>>>>> at >>>>>> org.apache.camel.component.cxf.CxfConsumer$1.invoke(CxfConsumer.java:85) >>>>>> at >>>>>> org.apache.cxf.interceptor.ServiceInvokerInterceptor$1.run(ServiceInvokerInterceptor.java:57) >>>>>> at >>>>>> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:441) >>>>>> at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303) >>>>>> at java.util.concurrent.FutureTask.run(FutureTask.java:138) >>>>>> at >>>>>> org.apache.cxf.workqueue.SynchronousExecutor.execute(SynchronousExecutor.java:37) >>>>>> at >>>>>> org.apache.cxf.interceptor.ServiceInvokerInterceptor.handleMessage(ServiceInvokerInterceptor.java:95) >>>>>> at >>>>>> org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:236) >>>>>> at >>>>>> org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInitiationObserver.java:89) >>>>>> at >>>>>> org.apache.cxf.transport.http_jetty.JettyHTTPDestination.serviceRequest(JettyHTTPDestination.java:302) >>>>>> at >>>>>> org.apache.cxf.transport.http_jetty.JettyHTTPDestination.doService(JettyHTTPDestination.java:265) >>>>>> at >>>>>> org.apache.cxf.transport.http_jetty.JettyHTTPHandler.handle(JettyHTTPHandler.java:70) >>>>>> at >>>>>> org.mortbay.jetty.handler.ContextHandler.handle(ContextHandler.java:766) >>>>>> at >>>>>> org.mortbay.jetty.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:230) >>>>>> at >>>>>> org.mortbay.jetty.handler.HandlerWrapper.handle(HandlerWrapper.java:152) >>>>>> at org.mortbay.jetty.Server.handle(Server.java:324) >>>>>> at >>>>>> org.mortbay.jetty.HttpConnection.handleRequest(HttpConnection.java:534) >>>>>> at >>>>>> org.mortbay.jetty.HttpConnection$RequestHandler.content(HttpConnection.java:879) >>>>>> at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:741) >>>>>> at org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:213) >>>>>> at org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:403) >>>>>> at >>>>>> org.mortbay.io.nio.SelectChannelEndPoint.run(SelectChannelEndPoint.java:409) >>>>>> at >>>>>> org.mortbay.thread.QueuedThreadPool$PoolThread.run(QueuedThreadPool.java:522) >>>>>> >>>>>> >>>>>> Where is the problem ? >>>>>> >>>>>> Regards, >>>>>> >>>>>> >>>>>> >>>>> >>>>> ----- >>>>> Charles Moulliard >>>>> SOA Architect >>>>> >>>>> My Blog : http://cmoulliard.blogspot.com/ >>>>> http://cmoulliard.blogspot.com/ >>>> >>>> >>> >>> >>> ----- >>> Charles Moulliard >>> SOA Architect >>> >>> My Blog : http://cmoulliard.blogspot.com/ >>> http://cmoulliard.blogspot.com/ >> >> >> > > > ----- > Charles Moulliard > SOA Architect > > My Blog : http://cmoulliard.blogspot.com/ http://cmoulliard.blogspot.com/ > -- > 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. > > -- Claus Ibsen Apache Camel Committer Open Source Integration: http://fusesource.com Blog: http://davsclaus.blogspot.com/ Twitter: http://twitter.com/davsclaus
