JSON的Camel绑定模式不起作用，无法将其解组到POJO

Question

我正在尝试将消息从 rest API 发送到新路由，即使您在我的 REST API 上收到 JSON 格式的请求并且绑定设置为 JSON，当我将其转发到新路由时，它将显示为 InputStream，我必须将其编组到 JSON 才能使用它。

我已经尝试在RestConfiguration中使用streamCaching和其他组件(consumes、produces、type、dataType)。我还使用了POM中的所有依赖项。

public void configure() {
    restConfiguration().component("servlet")
            .bindingMode(RestBindingMode.json)
            .skipBindingOnErrorCode(false);

    rest("/resttest")
       .patch("/t1")
            .id("t1")
            .description("t1")
            .consumes("application/json")
            .produces("application/json")
            .param()
                .name("body")
               .type(RestParamType.body)
               .dataType("json")
                .required(true)
            .endParam()
            .to("direct:test2");

这条路线在其他班级:

 from("direct:test2").id("test2")

            .marshal().json(JsonLibrary.Jackson,SomePOJO.class)
            .unmarshal().json(JsonLibrary.Jackson, SomePOJO.class)
            .choice()
            .when(simple("${body.getStatus()} =~ 'Closed'"))
            .....

我希望在test2路由上得到JSON消息，但不知何故我得到了InpuStream，所以我必须先做编组。有人知道如何让REST API将我转发到JSON格式的路由消息，而不是流吗？

Answer 1

我也遇到了同样的问题，我必须对传入的值应用marshal方法，对响应应用unmarshal方法。

我用的是这个代码：

rest(service.service)
.description(ContentCategory.api("Service Test"))           
.post("/product/{productType}/{enterpriseId}")
.description("service for saving a product")
.consumes(MediaType.APPLICATION_JSON)
.type(Product.class)
.bindingMode(RestBindingMode.json)
.produces(MediaType.APPLICATION_JSON)
.outType(String.class)
.route()
.bean("productService", "saveProduct")
.marshal()
.json(JsonLibrary.Jackson)
.setHeader(Exchange.CONTENT_TYPE, constant(MediaType.APPLICATION_JSON))
.endRest();

我只是在意识到我收到了一个输入流后添加了unmar的方法

rest(service.service)
.description(ContentCategory.api("Service Test"))           
.post("/product/{productType}/{enterpriseId}")
.description("service for saving a product")
.consumes(MediaType.APPLICATION_JSON)
.type(Product.class)
.bindingMode(RestBindingMode.json)
.produces(MediaType.APPLICATION_JSON)
.outType(String.class)
.route()
.bean("productService", "saveProduct")
.marshal()
.json(JsonLibrary.Jackson)
.unmarshal()
.json(JsonLibrary.Jackson)
.setHeader(Exchange.CONTENT_TYPE, constant(MediaType.APPLICATION_JSON))
.endRest();

事实上，我只是加了两行

.unmarshal()
.json(JsonLibrary.Jackson)

它认为您可能需要对restest服务使用解组方法。

Answer 2

尝试：

.convertBodyTo(String.class)

在你解组之前。