[
https://issues.apache.org/jira/browse/CAMEL-6367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13661742#comment-13661742
]
Willem Jiang commented on CAMEL-6367:
-------------------------------------
I think you need to update your customer processor, to send the exchange to
both file endpoint if you got the last exchange from the spliter.
> The logic in stream producer should sync (lock) and not per method which is
> wrong
> ---------------------------------------------------------------------------------
>
> Key: CAMEL-6367
> URL: https://issues.apache.org/jira/browse/CAMEL-6367
> Project: Camel
> Issue Type: Bug
> Components: camel-stream
> Affects Versions: 2.11.0
> Reporter: jeff
>
> A new option is available for the stream:file to close it when done
> (closeOnDone). This option is appeared in 2.11 after my jira
> (https://issues.apache.org/jira/browse/CAMEL-6147)
> File unlock (or released or closed) looks to doesn't works fine if last line
> is not passed to the endpoint
> Example :
> We have a CSV with X line. We want to write a part of it in a file out_1.csv
> and a second part in a file out_2.csv according to a business rule, in my
> example the rule is after two lines readed.
> An example is :
> from("file://C:/Temp/camel/rep1/?noop=true")
> .log("start process file => ${file:name}")
> .split()
> .tokenize("\n")
> .streaming()
> .process(new Processor() {
>
> public void process(Exchange exchange) throws Exception {
> // After 2 lines, next lines are rejected via an exchange
> property
> i++ ;
> if( i > 2) {
> exchange.setProperty("FILE_1", true );
> } else {
> exchange.setProperty("FILE_1", false);
> }
> }
> })
> .choice()
> .when(property("FILE_1").isEqualTo(Boolean.TRUE))
>
> .to("stream:file?fileName=C:/Temp/camel/rep1/out/out_1.csv&closeOnDone=true")
> .when(property("FILE_2").isEqualTo(Boolean.TRUE))
>
> .to("stream:file?fileName=C:/Temp/camel/rep1/out/out_2.csv&closeOnDone=true")
> .end()
> .end()
> .log("end process file => ${file:name}")
> .end()
> ;
> It create two files, and out_1.csv is still locked.
> Solution : Seems like the logic in stream producer should sync (lock) and not
> per method which is wrong.
> Or maybe better yet do not have a shared output stream.
> By the way, the problem appears not on if there are two files. It appears if
> the last exchange is not passed to the endpoint.
> Example with only one file :
> from("file://C:/Temp/camel/rep1/?noop=true")
> .split()
> .tokenize("\n")
> .streaming()
> .process(new Processor() {
> public void process(Exchange exchange) throws Exception {
> // After 2 lines, next lines are rejected via an
> // exchange property
> i++;
> if (i > 2) {
> exchange.setProperty("FILE_1", false);
> } else {
> exchange.setProperty("FILE_1", true);
> }
> }
> })
> .choice()
> .when(property("FILE_1").isEqualTo(Boolean.TRUE))
>
> .to("stream:file?fileName=C:/Temp/camel/rep1/out/out_1.csv&closeOnDone=true")
> .end()
> .end()
> .end();
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
