0

我正在拆分一些 java 对象,然后进行聚合。我有点困惑这种完成策略如何与骆驼(2.15.2)一起使用。我正在使用完成大小和完成超时。如果我理解正确,完成超时对它没有太大影响。因为,这里没有太多的等待。

总共,我有 3000 多个对象。但是,似乎只有一部分是聚合的。但是,如果我改变完成大小值,情况就会改变。如果大小为100,则聚合在800左右,如果是200,则聚合到1600左右。但是,我事先不知道对象的大小,因此不能依赖假设的数字。

谁能向我解释我在这里做错了什么?如果我使用 eagerCheckCompletion,它会一次性聚合整个事情,这是我不想要的。下面是我的路线:

   from("direct:specializeddatavalidator")
        .to("bean:headerFooterValidator").split(body())
        .process(rFSStatusUpdater)
        .process(dataValidator).choice()
        .when(header("discrepencyList").isNotNull()).to("seda:errorlogger")
        .otherwise().to("seda:liveupdater").end();


    from("seda:liveupdater?concurrentConsumers=4&timeout=5000")
        .aggregate(simple("${in.header.contentType}"),
                batchAggregationStrategy())
        .completionSize(MAX_RECORDS)
        .completionTimeout(BATCH_TIME_OUT).to("bean:liveDataUpdater");

    from("seda:errorlogger?concurrentConsumers=4")
        .aggregate(simple("${in.header.contentType}"),
                batchAggregationStrategy("discrepencyList"))
        .completionSize(MAX_RECORDS_FOR_ERRORS)
        .completionTimeout(BATCH_TIME_OUT)
        .process(errorProcessor).to("bean:liveDataUpdater");
4

1 回答 1

1

很奇怪,但如果你想聚合所有拆分的消息,你可以简单地使用

.split(body(), batchAggregationStrategy())

根据您希望它的工作方式,您可以使用

.shareUnitOfWork().stopOnException()

有关更多信息,请参见http://camel.apache.org/splitter.html

于 2015-08-28T08:48:24.533 回答