That is the best practice for do it ?
2013/3/8 Jean Francois LE BESCONT <jflebesc...@gmail.com> > Thanks Marco ! > > It is an idea ! Claused to the Composed Message Processor ( > http://camel.apache.org/composed-message-processor.html paragraph Example > using only Splitter). > > I am really suprised to have to make a such tips, it looks very > complicated for a simple use case no ? > > > 2013/3/8 Marco Westermann <marwesterm...@gmx.de> > >> Hi, >> >> maybe you can process this by using a bean. Then you can open the stream >> at the beginning and close it at the end. I try to show you what I mean: >> >> FileWriterBean fwBean = new FileWriterBean(); >> >> public void configure() { >> from("file://") >> .bean(fwBean, "openFileForProcessing") >> .split().tokenize("\n") >> // do your enrichment >> .bean(fwBean, "writeLine") >> .end() >> .bean(fwBean, "closeFile"); >> } >> >> regards, Marco >> >> >> Am 08.03.2013 12:23, schrieb Jean Francois LE BESCONT: >> >> Thanks Willem for help. >>> >>> My explaination are sometime to complicate, I will present it >>> differently. >>> >>> I have a "big" file to process efficiently, for that if I have tried : >>> >>> Method 1 : >>> from("file://C:/Temp/camel/**input_test/?noop=true") >>> .split() >>> .tokenize("\n") >>> // Business logic with possible reject and enrich >>> .recipientList( >>> simple("stream:file?fileName=**C:/Temp/camel/output_test/out.**csv")) >>> .end() >>> .end() >>> .end(); >>> >>> With this method, my process take 11 seconds but my file is not released >>> (windows file is locked in windows). >>> >>> So I try with append : >>> >>> Method 2 : >>> >>> from("file://C:/Temp/camel/**input_test/?noop=true") >>> .split() >>> .tokenize("\n") >>> // Business logic with possible reject and enrich >>> >>> .to("file://?fileName=C:/Temp/**camel/output_test/out.csv&** >>> fileExist=Append") >>> .end() >>> >>> .end(); >>> >>> File is not locked after but it take 1,40 minutes ... >>> >>> I finally try with the aggregate : >>> >>> Method 3 : >>> >>> from("file://C:/Temp/camel/**input_test/?noop=true") >>> .split() >>> .tokenize("\n") >>> // Business logic with possible reject and enrich >>> .aggregate(header(Exchange.**FILE_NAME_ONLY), new >>> BodyInAggregatingStrategy()) >>> .completionTimeout(3000) >>> .to("file://C:/Temp/camel/**output_test/") >>> .end() >>> .end() >>> .end(); >>> >>> As the example, but the process never finish, so I try to specify >>> completionSize(7500) and completionTimeout(15000) but my output file >>> doesn't contains all my row ( only 1 %). I have not find an example of >>> how >>> to use these parameters ... >>> >>> Please, what should I do to have a process efficient and with no lock ? >>> >>> Thanks >>> >>> JF >>> >>> >> >
