NotifyBuilder看到的骆驼分离器产生不正确的完成交换数？

Question

我正在使用Camel 2.10.3。

假设我有一条类似于以下内容的路线：

from("direct:split")
  .routeId("split-ti-analytics-events")
  .split().method(JsonArraySplitter.class,"split")
  .parallelProcessing()
  .log("Received: ${body}")
  .to("stub:direct:somewhere");

一个测试类在通知生成器之后执行该操作，以断言我的拆分器正在执行它应该执行的操作。

@Test(description = "Asserts that when we receive a json event that we properly split the " +
            "events if the payload was a json array.")
public void testReceiveTiAnalyticsArrayOfJsonEvents() {
    NotifyBuilder notifier = new NotifyBuilder(context)
      .wereSentTo("stub:direct:somewhere")
      .whenExactlyDone(7)
      .create();
      producerTemplate.sendBody("direct:split", sampleEventsInArrayJsonString);

      assertTrue(notifier.matches(5, TimeUnit.SECONDS));
}

假设sampleEventsInArrayJsonString是一个json数组，如下所示:

[{},{},{},{},{},{},{}]

其中，该json数组中有7个对象元素。

测试几乎会立即失败。但是，测试的输出清楚地显示了7条“已收到：{}”的日志消息。

现在，有趣的部分来了...如果我设置了。当ExactlyDone(8)时，测试通过。第八条信息究竟会来自哪里？我很想说这个测试是有效的，就到此为止，因为我知道它至少从那个json数组中分离出了消息(忽略我没有验证NotifyBuilder中的内容的事实)，但是我担心实际上有第8个交换通过不属于它的route发送。NotifyBuilder看到通过该路由完成的8次交换而不是7次交换的原因是什么？

Answer 1

是的，这是骆驼的一只小虫子。我已经在测试中记录了一张罚单和一个有效的修复程序https://issues.apache.org/jira/browse/CAMEL-6255