hello,

      I am try to send a message to a queue when the file componenet starts
processing any file. But I since I am using XML DSL not sure how to
configure it.
      I am setting the Body with a different value just for the message.
This is causing the processing to not go forward. Since I am using
pararllelprocessing I can't write the logic inside the split since I am not
sure if the First message will always the one I have sent First.

      I also thought of pollenrich but still I feel it will  boil back to
same issue.  My route configured.is currently.  Any ideas ?


         <route customId="false" id="routeCSV" xmlns="
http://camel.apache.org/schema/spring";>
                  <from
uri="file://C:\\CSVDATA\\IN?noop=true&amp;delay=500&amp;readLock=true&amp;charset=utf-8"/>
                         <process ref="CustomHeaderProcessor" />
                         <setHeader headerName="DATASOURCEID">
                          <simple resultType="java.lang.Integer">8</simple>
                       </setHeader>
                         <setHeader headerName="MESSAGE_TYPE">
                                <constant>START</constant>
                          </setHeader>
                         <setBody >
                             <constant>START</constant>
                        </setBody>
                    <to
uri="rabbitmq://localhost/FMASTER?autoDelete=false&amp;queue=SMASTERQUEUE&amp;username=guest&amp;password=guest&amp;routingKey=SMASTER"/>
        <split id="splitCSV" streaming="true"  parallelProcessing="true">
             <tokenize token="\n"/>
             <filter>
               <simple>${property.CamelSplitIndex} > 0</simple>
               <unmarshal>
                   <csv useMaps="true">
                      <header>........................




regards,
Felix T

Reply via email to