Apache Camel EIP路由-如何停止拆分（）

Question

我对以下路线有一些问题：

// from("cxf:....")...
from("direct:start").process(startRequestProcessor) // STEP 1
            .choice()
                .when(body().isNull())
                        .to("direct:finish")
                .otherwise()
                    .split(body())  // STEP 2
                    .bean(TypeMapper.class) // STEP 3
                    .log("Goes to DynamicRouter:: routeByTypeHeader with header: ${headers.type}")
                    .recipientList().method(Endpoint1DynamicRouter.class, "routeByTypeHeader") // STEP 4
                    .ignoreInvalidEndpoints();

    from("direct:endpoint2") // STEP 6
            .log("Goes to DynamicRouter::routeByCollectionHeader with header: ${headers.collection}")
            .recipientList().method(Endpoint2DynamicRouter.class, "routeByCollectionHeader")
            .ignoreInvalidEndpoints();

    from("direct:endpoint1.1") // STEP 5
            .process(new DateRangeProcessor())
            .to("direct:collections");

    from("direct:endpoint1.2") // STEP 5
            .process(new SingleProcessor())
            .to("direct:collections");


    from("direct:endpoint2.2") // STEP 7
            .aggregate(header("collection" /** endpoint2.2 */), CollectionAggregationStrategy)
            .completionSize(exchangeProperty("endpoint22"))

            .process(new QueryBuilderProcessor())
            .bean(MyService, "getDbCriteria")

            .setHeader("collection", constant("endpoint2.1"))
            .to("direct:endpoint2.1").end();


    from("direct:endpoint2.1") // STEP 8
            .aggregate(header("collection" /** endpoint2.1 */), CollectionAggregationStrategy)
            .completionSize(exchangeProperty("CamelSplitSize"))
            .to("direct:finish").end();

    from("direct:finish")
            .process(new QueryBuilderProcessor())
            .bean(MyRepository, "findAll")
            .log("ResponseData: ${body}").
            marshal().json(JsonLibrary.Gson).end();

路线

1. 接收json字符串并将其转换为JSONObject的列表（HashSet）。
2. 将收到的列表分割为json对象。
3. 根据对象内容设置相应的头
4. 根据报头将消息路由到endpoint 1.1或endpoint 1.2
5. 将消息转换为mongodb标准并发送到endpoint 2
6. endpoint2根据另一个报头将消息路由到endpoint2.1或endpoint2.2。
7. Endpoint 2.2聚合所有接收到的消息，处理它以获得mongodb标准并将其发送到endpoint 2.1（在步骤2中计算完成大小并保存在属性endpoint 22中）。
8. Enpoint 2.1聚合所有消息（CamelSplitsize）将聚合消息转换为查询对象，并将其发送到存储库以检索数据。

我可以在调试器中看到有效的响应对象，但无论如何我都会遇到一个错误：

未找到java类的消息正文编写器。util。HashSet，ContentType:application/json

问题不在response对象中，因为它与其他路由一起工作，并且它不包含哈希集。

我猜route会将在第1步创建的哈希集发送到输出。。。

我的问题是：

>

路由输出出了什么问题？

两个接收者列表（）都尝试将消息转发到无效的终结点（我必须使用。

组织。阿帕奇。骆驼NoSuchEndpointException:找不到：org的终结点。springframework。数据mongodb。果心查询Criteria@20f55e70，请检查您的类路径是否包含所需的Camel组件jar。

任何帮助都将不胜感激！谢谢

Answer 1

我觉得很奇怪，但是。聚合（）函数不回复交换。它使用聚合策略，但总是回复传入的交换。这在阅读留档时不清楚，但你必须使用聚合策略和分裂（）才能返回交换。