用于多源特定消息聚合和重定向到目的地的Camel模式

Question

<route id="routeId">
    <from uri="Source1"/>
    <from uri="Source2"/>
    <to   uri="Destination"/>
</route>

提前谢了。

Answer 1

Camel聚合器和过滤器模式可用于此场景...

• 使用筛选器检测“结束”消息并通过聚合器路由它们
• 使用自定义聚合策略构建带有计数的单端消息
• 使用自定义完成谓词触发完成消息

像这样的...

from("source1").to("direct:aggregateRoute"); 
from("source2").to("direct:aggregateRoute"); 
from("direct:aggregateRoute")
    .filter(header("isEndMessage").isEqualTo("true"))
        .aggregate(constant(true), new MyAggregationStrategy())
        .completionPredicate(new MyCompletionStrategy())
    .to("destination");