Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
MIME-Version: 1.0
Date: Tue, 8 Sep 2015 17:44:35 +0200
Message-ID: 
 <CA+Oxv+hxi1WaPv5PnNRmkfHrbi3JerraBNh+EPyhUSHh3+iUeg@mail.gmail.com>
Subject: Trigger a event to a queue when File component starts processing
 files
From: Felix Thomas <felix.thomas@gmail.com>
To: users@camel.apache.org
Content-Type: multipart/alternative; boundary=001a1139cc5838c317051f3e3ef0

--001a1139cc5838c317051f3e3ef0
Content-Type: text/plain; charset=UTF-8

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

--001a1139cc5838c317051f3e3ef0--