343.5. aggregate

INFO：请注意，此聚合策略需要预先完成检查才能正常工作。

在本例中，我们将输入目录中找到的所有文本文件汇集到一个存储在输出目录中的一个 Tar 文件中。

   from("file:input/directory?antInclude=*/.txt")
     .aggregate(new TarAggregationStrategy())
       .constant(true)
       .completionFromBatchConsumer()
       .eagerCheckCompletion()
   .to("file:output/directory");

   from("file:input/directory?antInclude=*/.txt")
     .aggregate(new TarAggregationStrategy())
       .constant(true)
       .completionFromBatchConsumer()
       .eagerCheckCompletion()
   .to("file:output/directory");

Copy to Clipboard

Toggle word wrap

传出的 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");

   from("file:input/directory?antInclude=*/.txt")
     .aggregate(new TarAggregationStrategy())
       .constant(true)
       .completionFromBatchConsumer()
       .eagerCheckCompletion()
     .setHeader(Exchange.FILE_NAME, constant("reports.tar"))
   .to("file:output/directory");

Copy to Clipboard

Toggle word wrap

返回顶部

343.5. aggregate

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links