Did you set the stopOnException option to be true in your multicast? -- Willem Jiang
Red Hat, Inc. FuseSource is now part of Red Hat Web: http://www.fusesource.com | http://www.redhat.com Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/) (English) http://jnn.iteye.com (http://jnn.javaeye.com/) (Chinese) Twitter: willemjiang Weibo: 姜宁willem On Friday, May 17, 2013 at 2:00 AM, Nibs wrote: > Hi > I am using camel 2.4 > I know its a old version of camel but I need a help badly > > I am using multiacast to process same message differently. > I wanted to replies from both the message ,so if one endpoint fails to > process the message ,the 2nd endpoint also stop the processing and the > message will go to the errorHandle block. > for that i am using customAggregationStrategy so i can get a control of both > the endpoints . > > But dont know what is wrong in my code because control never enters in > customAggregationStrategy class > So i cant check the replies from endpoints > > Please look the code below and help me out > > > > > > <bean id="aggregatorStrategy1" class="com.E_AggregationStrategy" /> > <bean id="reslutData" class="com.E_AggregationStrategy" /> > > > - <route id="xmlProcessing" trace="false" > > <from uri="direct:xmlPrcessing" /> > <convertBodyTo type="java.lang.String" /> > > - <doTry> > - <choice> > - <when> > <simple>${header.CamelFileNameOnly} contains > ${properties:xml_prefix}</simple> > - <setHeader headerName="org"> > <xpath>eformular/forminfo/orgg/text()</xpath> > </setHeader> > - <setHeader headerName="efname"> > <xpath resultType="String">eformular/forminfo/ename/text()</xpath> > </setHeader> > > <process ref="testProcessor" /> > > > - <routingSlip> > <header>xsdFile</header> > </routingSlip> > > <log loggingLevel="INFO" message="!!!!!!!!Header Check My ::: > ${header.checkMyc}" /> > - <choice> > - <when> > <simple>${header.checkMyC} == 'YES'</simple> > <convertBodyTo type="java.lang.String" /> > > - <multicast stopOnException="true" strategyRef="aggregatorStrategy1" > parallelProcessing="true"> > <to uri="direct:outbox" /> > <to uri="direct:Commitprocessing" /> > </multicast> > <convertBodyTo type="java.lang.String" /> > <bean ref="resultData" method="result_out" /> > - <choice> > - <when> > <simple>${header.OUTBOX} == null</simple> > <log loggingLevel="INFO" message="After multicast body for outbox > ${body}!!!!!!!!!!!!!!" /> > </when> > - <when> > <simple>${header.MEP} != null</simple> > <log loggingLevel="INFO" message="After multicast body for MEP > ${body}!!!!!!!!!!!!!!" /> > </when> > </choice> > <log loggingLevel="INFO" message="after multicast > ::${header.CamelFileNameOnly}" /> > </when> > - <otherwise> > > <log loggingLevel="INFO" message="do nothing !!!!!!!!!!!!!!!" /> > </otherwise> > </choice> > </when> > - <otherwise> > <log loggingLevel="INFO" message="!!!!!!not an xml file" /> > <to uri="seda:attachments" /> > </otherwise> > </choice> > - <doCatch> > <exception>java.lang.Exception</exception> > - <handled> > <constant>true</constant> > </handled> > <log loggingLevel="ERROR" message=":::: ${exception} ${exception.message}" > /> > - > </doCatch> > </doTry> > </route> > - > - <route id="outbox" trace="false"> > <from uri="direct:outbox" /> > <convertBodyTo type="java.lang.String" /> > - > - <routingSlip> > <header>xsltFile</header> > </routingSlip> > <log loggingLevel="INFO" message="!!!!!!!!Aftere recipientList xslt: > ${header.CamelFileNameOnly}" /> > - <routingSlip> > <header>xsd_After_xslt</header> > </routingSlip> > - > </route> > - <route id="CommitEprocessing" trace="false"> > <from uri="direct:Commitprocessing" /> > <convertBodyTo type="java.lang.String" /> > > - <routingSlip> > <header>myCommitxsltFile</header> > </routingSlip> > - <routingSlip> > <header>xsd_ME_afterXslt</header> > </routingSlip> > > > </route> > - <route id="sucsess" trace="false"> > <from uri="direct:success" /> > <convertBodyTo type="java.lang.String" /> > > - <setHeader headerName="outbox"> > <simple>${properties:outbox}/${header.org (http://header.org)}/</simple> > </setHeader> > - <routingSlip> > <header>outbox</header> > </routingSlip> > > </route> > - </camelContext> > </beans> > > Thank you > > > > -- > View this message in context: > http://camel.465427.n5.nabble.com/camel-multicast-tp5732682.html > Sent from the Camel - Users mailing list archive at Nabble.com > (http://Nabble.com).
