如何将参数从Apache CXF传递到Camel

Question

public class MyInterceptor extends AbstractSoapInterceptor {
    //..... some variables 

     @Override
     public void handleMessage(SoapMessage message) throws Fault {
        //..some logic  and then setting a variable

        message.getExchange().put("Foo", "Bar");
     }
 }

...下面的类是骆驼处理器，它最终被调用：

public class MyCamelProcessor implements Processor {
    @Override
    public void process(Exchange exchange) throws Exception {
        //how can I read information from CXF Intercptor here? 
        //how can I read "Foo" value?           
    }
}

我知道Apache CXF使用的Exchange类与Camel使用的Exchange不同，但是这两种集成技术之间应该有一种传递信息的方式？

Answer 1

最后，我解决了它如何遵循：

在我的上下文中，我有一个带有camel-cxf组件的使用者服务，它被路由到处理器。

Camel中的CxfEndpoint类有一个调用SetInInterceptors的方法：

public void setInInterceptors(List<org.apache.cxf.interceptor.Interceptor<? extends org.apache.cxf.message.Message>> interceptors)

因此，如果我们在bean定义文件中定义下一个：

...
<cxf:cxfEndpoint id="consumerId" 
    address="/myservice"
    serviceClass="com.example.service.MyServiceSEI">
    <cxf:inInterceptors>
        <ref bean="myInterceptor"/>
    </cxf:inInterceptors>
</cxf:cxfEndpoint> 

<bean id="myInterceptor" class="com.example.interceptors.MyInterceptor" />  

然后，在我们的自定义拦截器中，我们可以设置映射中的任何变量

...
import org.apache.cxf.binding.soap.SoapMessage;
import org.apache.cxf.binding.soap.interceptor.AbstractSoapInterceptor;
...

public class MyInterceptor extends AbstractSoapInterceptor {
  public MyInterceptor() {
    super(Phase.RECEIVE);
  }

  @Override
  public void handleMessage(SoapMessage message) throws Fault {
    //..some logic  and then setting a variable

    message.getExchange().put("Foo", "Bar");
  }
}

最后，我们可以使用org.apache.cxf.message.Message类获取处理器中的变量，这与Exchange.getin（）方法使用的org.apache.camel.Message不同

import org.apache.camel.Exchange;
import org.apache.camel.Processor;
import org.apache.cxf.message.Message;
import org.apache.camel.component.cxf.common.message.CxfConstants;

public class MyCamelProcessor implements Processor {
    @Override
    public void process(Exchange exchange) throws Exception {
        //how can I read information from CXF Intercptor here? 
        //how can I read "Foo" value?
        Message cxfMessage = exchange.getIn().getHeader(CxfConstants.CAMEL_CXF_MESSAGE, Message.class); 
        String foo = (String) cxfMessage.getExchange().get("Foo");

        // read message from camel context
        org.apache.camel.Message inMessage = exchange.getIn();
        ...
    }
}