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&delay=500&readLock=true&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&queue=SMASTERQUEUE&username=guest&password=guest&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