Hi

I found room for improvement and trying to address this
https://issues.apache.org/jira/browse/CAMEL-9905

You can build from the source with this fix and test it on your system.


On Fri, Apr 22, 2016 at 8:40 PM, Claus Ibsen <claus.ib...@gmail.com> wrote:
> Make a shorter and simpler example and see what happens.
>
> Also are you running on windows? Then mind that it has such file
> problems with not able to delete/move files if not all streams has
> been carefully closed, even if they are from the same process that
> created it. All that works nicely on linux boxes.
>
> You can also debug and see if that DeleteTarFileOnCompletion is not
> called, that is the guy that deletes the temp file.
>
>
> On Fri, Apr 22, 2016 at 6:29 AM, sungkwon.eom <skeo...@gmail.com> wrote:
>> I'm using camel ver 2.17 and I added route code.
>>
>> thk
>>
>>
>>
>>                 from(src_uri).convertBodyTo(String.class)
>>                         .setHeader("REAL_AGGREGATION_ID",
>> constant("REAL_AGGREGATION"))
>>                         .log("Aggregation ${file:onlyname} ")
>>                         .aggregate(header("REAL_AGGREGATION_ID"), new
>> FileAggregationStrategy())
>>                         .completionSize(30).completionTimeout(100)
>>                         .setHeader(Exchange.FILE_NAME,
>> method(Camel_RouteBuilder.class, "setFileName_real"))
>>                         .setHeader("COMPRESS_ID", constant("COMPRESS"))
>>                         .log("Compress ${header.CamelFileName} ")
>>                         .aggregate(header("COMPRESS_ID"), new
>> TarAggregationStrategy(false,true)).completionSize(30)
>>                         .completionTimeout(100).log("Compressing
>> ${header.CamelFileName}").marshal()
>>                         .gzip().setHeader(Exchange.FILE_NAME,
>> method(Camel_RouteBuilder.class, "setFileName_gz"))
>>                         .log("Compresssed file name :
>> ${header.CamelFileName}")
>>                         .to(ftp_server_uri)
>>                         .process(new Processor(){
>>                                 @Override
>>                                 public void process(Exchange exchange)
>> throws Exception {
>>                                         List<List&lt;String>> db_data  =
>> exchange.getProperty("db_data", List.class);
>>                                         exchange.getIn().setBody(db_data);
>>                                 }})
>>                 .to("sql:update tr_trace set V_DESC = # WHERE P_TRIPSEQ =#
>> and P_FST_TIME = #?batch=true&dataSource=myDataSource")
>>                 .log("${headers.CamelSqlUpdateCount}  records
>> updated!!").log("${body}")
>>                 .end();
>>
>>
>>
>>
>> --
>> View this message in context: 
>> http://camel.465427.n5.nabble.com/TarAggregationStrategy-tmp-directory-is-full-tp5781302p5781524.html
>> Sent from the Camel - Users mailing list archive at Nabble.com.
>
>
>
> --
> Claus Ibsen
> -----------------
> http://davsclaus.com @davsclaus
> Camel in Action 2: https://www.manning.com/ibsen2



-- 
Claus Ibsen
-----------------
http://davsclaus.com @davsclaus
Camel in Action 2: https://www.manning.com/ibsen2

Reply via email to