Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
Received-SPF: pass (nike.apache.org: domain of jflebescont@gmail.com
 designates 209.85.214.174 as permitted sender)
MIME-Version: 1.0
In-Reply-To: 
 <CAJ5MdT9mqdFqFi_jxhT6rmLYDPaP5Wc1H=iffmaE7eAqZSzGVw@mail.gmail.com>
References: 
 <CAJ5MdT9gC+EXuu-JgJLvY4=7OPztRyE=FSRV_BviXMBjmLW_Rw@mail.gmail.com>
	<CAJ5MdT9XxWa=4cpTv3KV3r9e2PG0CtnhFgyGfbiQ7LNuZ7bLUA@mail.gmail.com>
	<CAGB5yNmnUVRuGv4BFfTekPpktq+Z+hKSrqgXCXP73bVouaHJ2Q@mail.gmail.com>
	<CAGB5yNk7cS44ZhbQVz7FCBMnim422QFJfmGX6YjQLoaVrHc=Lg@mail.gmail.com>
	<CAJ5MdT8ijtq+415f-DK+mH6+z6Gvc0oGvk4zo85K7h7WDzLA3Q@mail.gmail.com>
	<CAJ5MdT9kQkQ3CpKk2S0egi7PJqV1puDQX9cDBs1MmODJjarb0Q@mail.gmail.com>
	<CAJ5MdT_g=fRca6srMCOeaS_nDcZj5W3i0NsVxOz1JtZ2Rd8C6g@mail.gmail.com>
	<CAJ5MdT_=38PqwmxWFJGzFkjzhWRGsQ5h4JSSgvQshRG1VMRqNQ@mail.gmail.com>
	<CAJ5MdT9mqdFqFi_jxhT6rmLYDPaP5Wc1H=iffmaE7eAqZSzGVw@mail.gmail.com>
Date: Tue, 21 May 2013 09:47:38 +0200
Message-ID: 
 <CAJ5MdT-mG2Bh+HoyHoAH+EyEyp3biFei-VeaE1hznQmYTWpE9Q@mail.gmail.com>
Subject: Re: stream:file closeOnDone not close all time
From: Jean Francois LE BESCONT <jflebescont@gmail.com>
To: users@camel.apache.org
Content-Type: multipart/alternative; boundary=089e0149cb8ec67d4304dd35a9e8

--089e0149cb8ec67d4304dd35a9e8
Content-Type: text/plain; charset=ISO-8859-1

Hi,

Sorry if I spam ( I also speak in jira )

Hi,

( Sorry if I spam, I also speak in jira )


I have found a solution, based on the idea of send the exchange to both
endpoint :

public void configure() throws Exception {

      // Properties
      final String PROP_WRITE_IN_FILE_1 = "PROP_WRITE_IN_FILE_1";
      final String PROP_WRITE_IN_FILE_2 = "PROP_WRITE_IN_FILE_2";

      // Routes
      final String ROUTE_FILE_1 = "direct:ROUTE_FILE_1" ;
      final String ROUTE_FILE_2 = "direct:ROUTE_FILE_2" ;

      // MAIN ROUTE
      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(PROP_WRITE_IN_FILE_1, true);
                  exchange.setProperty(PROP_WRITE_IN_FILE_2, false);
               } else {
                  exchange.setProperty(PROP_WRITE_IN_FILE_1, false);
                  exchange.setProperty(PROP_WRITE_IN_FILE_2, true);
               }
            }
         })
         .multicast().parallelProcessing()
            .to(ROUTE_FILE_1  , ROUTE_FILE_2 )
         .end()
         .log("end process file => ${file:name}")
      .end();

      // OUT FILE 1
      from(ROUTE_FILE_1)
         .process(new Processor() {
            public void process(Exchange exchange) throws Exception {
               if( ! exchange.getProperty(PROP_WRITE_IN_FILE_1,
Boolean.class).booleanValue())
               exchange.getIn().setBody(null);
            }
         })

 .to("stream:file?fileName=C:/Temp/camel/rep1/out/out_1.csv&closeOnDone=true")
      .end();

      // OUT FILE 2
      from( ROUTE_FILE_2)
      .process(new Processor() {
            public void process(Exchange exchange) throws Exception {
               if( ! exchange.getProperty(PROP_WRITE_IN_FILE_2,
Boolean.class).booleanValue())
               exchange.getIn().setBody(null);
            }
         })

 .to("stream:file?fileName=C:/Temp/camel/rep1/out/out_2.csv&closeOnDone=true")
      .end();

   }


It complicate the process but it works...

For me camel doesn't manage correctly the Content Based Router from the EIP
patterns in the file:stream component

--089e0149cb8ec67d4304dd35a9e8--