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<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.