camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Willem jiang <willem.ji...@gmail.com>
Subject Re: camel multicast
Date Fri, 17 May 2013 01:24:31 GMT
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).




Mime
View raw message