骆驼代理和替换交换体

Question

我已经创建了一个服务代理。

代理（请求类型为TypeA）和实际服务（请求类型TypeB。）之间有一个处理器。

进入< code > process(Exchange Exchange)方法的交换体属于< code>TypeA。

我能够使用下面的代码行访问数据

TypeA typeA = exchange.getIn().getBody(TypeA.class);

现在，我想将此信息更改为TypeB。

我使用下面的代码添加主体。

exchange.getIn().setBody(typeA); 

我得到了java.lang.IllegalArgumentExc的：参数类型不匹配

现在，我想使用Exchange调用真正的服务，它来自Processor。

我尝试进入处理器，但出现以下异常

java.lang.IllegalArgumentException: argument type mismatch
        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:606)
        at org.apache.cxf.databinding.AbstractWrapperHelper.createWrapperObject(AbstractWrapperHelpe

真正的Web服务没有被调用。

如何解决这个问题。

我在代理中使用POJO模式。

Answer 1

这没有任何问题：

private static class ResetBodyRouteBuilder extends RouteBuilder {
    @Override
    public void configure() {
        from("direct:start")
            .process(new Processor() {
               @Override
               public void process(final Exchange exchange) throws Exception {
                   final ClassA a = exchange.getIn().getBody(ClassA.class);
                   LOG.info("body = " + a);
                   exchange.getIn().setBody(new ClassB());  // reset the body
               }
            })
            .log("body = ${body}");
    }
}

public class ClassA {
    @Override
    public String toString() {
        return "I'm A";
    }
};

public class ClassB {
    @Override
    public String toString() {
        return "I'm B";
    }
};

这将打印:

[                          main] ResetBody                      INFO  body = I'm A
[                          main] route1                         INFO  body = I'm B