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

Reply via email to