我的camel项目收到一个url,它充当代理并向具有如下路由定义的休息服务发送GET请求:

rest("/car")
  .get("/{id}")
  .param().name("id").type(RestParamType.path)
  .dataType("int").endParam()
  .to("http://0.0.0.0:8081?bridgeEndpoint=true")
  .consumes("application/json")
  .to("direct:jsoncar");

from("direct:jsoncar")
  .streamCaching()
  .log("log:${body}")
  .process(new Processor() { 
     public void process(Exchange exchange) throws Exception { 
        String data = exchange.getIn().getBody(String.class); 
        ...
        ...
     }
});

其余服务在流中发送回json . 问题是身体总是空的 . 我在很多方面尝试过:

from("direct:jsoncar")
  .streamCaching()
  .setHeader(Exchange.CONTENT_TYPE,constant("text/json"))
  .marshal().json(JsonLibrary.Jackson, true)
  .process(new Processor() {
     public void process(Exchange exchange) throws Exception {
       String dto = exchange.getIn().getBody(String.class);
       ...
     });

但它总是空的 . 请问,任何人都知道问题的性质吗?