import org.apache.cxf.ws.addressing.WSAddressingFeature; //导入依赖的package包/类
@Test
public void testDecoupledEndpoint() throws Exception {

    JaxWsServerFactoryBean serverFactory = new JaxWsServerFactoryBean();
    serverFactory.setAddress("zmq:(tcp://*:" + ZMQ_TEST_PORT + "?socketOperation=bind&socketType=pull)");
    serverFactory.setServiceClass(HelloWorldImpl.class);
    Server server = serverFactory.create();

    JaxWsProxyFactoryBean clientFactory = new JaxWsProxyFactoryBean();
    clientFactory.setServiceClass(HelloWorldPortType.class);
    clientFactory.setAddress("zmq:(tcp://localhost:" + ZMQ_TEST_PORT + "?socketOperation=connect&socketType=push)");
    clientFactory.getFeatures().add(new WSAddressingFeature());

    HelloWorldPortType client = (HelloWorldPortType) clientFactory.create();

    ClientProxy.getClient(client).getEndpoint()
                                 .getEndpointInfo()
                                 .setProperty("org.apache.cxf.ws.addressing.replyto",
                                              "zmq:(tcp://127.0.0.1:5555?socketOperation=connect&socketType=push)");

    String reply = client.sayHello("Claude");

    server.stop();

    assertEquals("Hello Claude", reply);
}
 

import org.apache.cxf.ws.addressing.WSAddressingFeature; //导入依赖的package包/类
private JaxWsProxyFactoryBean getBean(String endpointAddress) {
    JaxWsProxyFactoryBean f = new JaxWsProxyFactoryBean();
    f.setBindingId(SOAPBinding.SOAP12HTTP_BINDING);
    f.getFeatures().add(new WSAddressingFeature());
    f.setAddress(endpointAddress);
    return f;
}
 

import org.apache.cxf.ws.addressing.WSAddressingFeature; //导入依赖的package包/类
protected <T extends Client> T createPortProxy() {
    final Service service = Service.create(getServiceName());
    service.addPort(getServiceName(), SoapVersion.SOAP_12.equals(getSoapVersion()) ? SOAPBinding.SOAP12HTTP_BINDING : SOAPBinding.SOAP11HTTP_BINDING, getEndpointAddress());
    final T portTypeProxy = wsAddressingEnabled ?
            service.getPort(getServiceName(), getPortTypeClass(), new WSAddressingFeature()) :
            service.getPort(getServiceName(), getPortTypeClass());
    return portTypeProxy;
}
 

import org.apache.cxf.ws.addressing.WSAddressingFeature; //导入依赖的package包/类
private static void checkAddressingEnabled(org.apache.cxf.endpoint.Endpoint e) {
    for (Feature feature : e.getActiveFeatures()) {
        if (feature instanceof WSAddressingFeature) {
             //TODO: remove this DecoupledFaultHandler once CXF is upgraded, see JBWS-3516
            e.getInInterceptors().add(new DecoupledFaultHandler());
            e.getOutInterceptors().add(new AddressingInterceptor());
            e.getOutFaultInterceptors().add(new AddressingInterceptor());
            break;
        }
    }
}
 

import org.apache.cxf.ws.addressing.WSAddressingFeature; //导入依赖的package包/类
private static void checkAddressingEnabled(org.apache.cxf.endpoint.Endpoint e) {
    for (Feature feature : e.getActiveFeatures()) {
        if (feature instanceof WSAddressingFeature) {
             //TODO: remove this DecoupledFaultHandler once CXF is upgraded, see JBWS-3516
            e.getInInterceptors().add(new DecoupledFaultHandler());
            e.getOutInterceptors().add(new CXF3AddressingInterceptor());
            e.getOutFaultInterceptors().add(new CXF3AddressingInterceptor());
            break;
        }
    }
}