Агрегат затем разбивается на Apache Camel

Question

После агрегации я пытаюсь разделить обмен, который представляет собой группу обменов. Но внутри раскола элементы группы равны нулю.

Я использую Apache Camel 2,17 (верблюд-жильный, верблюд-FTP и верблюжью Scala)

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 следует использовать для получения простой агрегации на основе списка.