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}/</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.
