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/ -- View this message in context: http://www.nabble.com/Camel-2.0---Multicast-issue----tp22725597p22737641.html Sent from the Camel - Users mailing list archive at Nabble.com.
