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.

Reply via email to