Apache Camel RESTendpoint不返回最终主体

Question

我声明了一个RESTendpoint，它使用direct调用另一个路由。在第二条路由的末尾，我记录了正文，但它与返回到浏览器的正文不同。

@Component
public class EntidadeRoute extends RouteBuilder {

    @Override
    public void configure() throws Exception {
        restConfiguration().bindingMode(json);

        rest("/entidade")
            .get("/{id}")
                .to("direct:search-by-id");

        from("direct:search-by-id")
            .routeId("search-by-id")
            .setProperty("idEntidade", simple("${header.id}"))
            .pollEnrich("file:files/mock/dados?noop=true&idempotent=false")
            .unmarshal().json(JsonLibrary.Jackson)
            .split(jsonpath("$"))
            .filter(jsonpath("$[?(@.id == ${property.idEntidade})]"))
            .marshal().json(JsonLibrary.Jackson)
            .log("${body}");
    }
}

我知道拆分和过滤器正在工作，因为我在最后一行代码中记录了正文，这就是日志中出现的内容：

2021-04-28 18:15:15.707信息3905542---[nio-8080-exec-1]按ID搜索：{“ID”：“1”,“Tipo”：“PF”,“NOME”：“João Maria”}

但这是返回给浏览器的内容(entidades.json文件的确切内容）：

[{“id”：“1”，“tipo”：“pf”，“nome”：“若昂·玛丽亚”}，{“id”：“2”，“tipo”：“pf”，“nome”：“玛丽亚·若昂”}，{“id”：“3”，“tipo”：“pf”，“nome”：“若昂·席尔瓦”}，{“id”：“4”，“tipo”：“pf”，“nome”：“何塞·索萨”}]

为什么记录的正文与浏览器中显示的不一样，并修复它？

PS：如果我删除这些封送和反封送调用，我会在浏览器中得到以下错误：

Answer 1

错误是我需要将aggregationStrategy传递给split。我还需要停止记录主体，因为它正在消耗InputStream。在此之后，我可以安全地删除那些封送和反封送调用。

这是最后的代码：

@Component
public class EntidadeRoute extends RouteBuilder {

    @Override
    public void configure() throws Exception {
        restConfiguration().bindingMode(json);

        rest("/entidade")
            .get("/{id}")
                .to("direct:search-by-id");

        from("direct:search-by-id")
            .routeId("search-by-id")
            .setProperty("idEntidade", simple("${header.id}"))
            .pollEnrich("file:files/mock/dados?noop=true&idempotent=false")
            .split(jsonpath("$"), takeFirst(Exchange.FILTER_MATCHED))
                .filter(jsonpath("$[?(@.id == ${property.idEntidade})]")).stop()
            .end();
    }

    private AggregationStrategy takeFirst(String matchProperty) {
        return ((oldExchange, newExchange) -> {
            if (oldExchange == null && newExchange.getProperty(matchProperty, Boolean.class)) {
                oldExchange = newExchange;
            }
            return oldExchange;
        });
    }
}