聚合然後分裂與阿帕奇駱駝

Question

聚合後，我試圖分裂交換是一組交易所。但在分組內部，該組的元素爲空。

我使用Apache的駱駝2.17（駱駝核心，駱駝ftp和駱駝斯卡拉）

from("sftp://user@host/path?password=pass") 
.setHeader("tag", extractTagFromFilename) 
.aggregate(header("tag"), new GroupedExchangeAggregationStrategy()) 
.completionSize(3) // i want 3 files per group 
.split(_.in) 
    .process{m => println("== > " + m.in[])} 
.end() 
//.process{m => println("")} // btw this does not compile, why ? 
.log("${body}") 

==>空

==>空

==> null

爲什麼組中的元素爲空？

Answer 1

要解決此問題，聚合策略必須是GroupedMessageAggregationStrategy而不是GroupedExchangeAggregationStrategy。

文檔不是最新的，應該提到「.groupExchanges（）」已被棄用，應該使用GroupedMessageAggregationStrategy來獲得簡單的基於列表的聚合。