342.5. aggregate
INFO:请注意,此聚合策略需要预先完成检查才能正常工作。
在本例中,我们将输入目录中找到的所有文本文件汇集到一个存储在输出目录中的一个 Tar 文件中。
from("file:input/directory?antInclude=*/.txt")
.aggregate(new TarAggregationStrategy())
.constant(true)
.completionFromBatchConsumer()
.eagerCheckCompletion()
.to("file:output/directory");
传出的 CamelFileName 消息标头使用 java.io.File.createTempFile 创建,带有 ".tar" 后缀。 如果要覆盖此行为,您可以在路由中明确设置 CamelFileName 标头的值:
from("file:input/directory?antInclude=*/.txt")
.aggregate(new TarAggregationStrategy())
.constant(true)
.completionFromBatchConsumer()
.eagerCheckCompletion()
.setHeader(Exchange.FILE_NAME, constant("reports.tar"))
.to("file:output/directory");