> [
https://issues.apache.org/activemq/browse/CAMEL-118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#action_40033 ]
>
> James Strachan commented on CAMEL-118:
> --------------------------------------
>
> Here are the rejections from TextMate (which seems to give the best rejection messages)
>
> {code}
> ***************
> *** 16,42 ****
> */
> package org.apache.camel.component.cxf;
>
> - import java.net.URI;
> import java.util.Map;
>
> import org.apache.camel.CamelContext;
> import org.apache.camel.Endpoint;
> import org.apache.camel.impl.DefaultComponent;
> - import org.apache.cxf.Bus;
> - import org.apache.cxf.BusException;
> - import org.apache.cxf.bus.CXFBusFactory;
> - import org.apache.cxf.service.model.EndpointInfo;
> - import org.apache.cxf.transport.DestinationFactoryManager;
> - import org.apache.cxf.transport.local.LocalTransportFactory;
> - import org.xmlsoap.schemas.wsdl.http.AddressType;
>
> /**
> * Defines the <a href="
http://activemq.apache.org/camel/cxf.html">CXF Component</a>
>
> * @version $Revision$
> */
> public class CxfComponent extends DefaultComponent<CxfExchange> {
> - private LocalTransportFactory localTransportFactory;
>
> public CxfComponent() {
> }
> --- 16,36 ----
> */
> package org.apache.camel.component.cxf;
>
> import java.util.Map;
>
> import org.apache.camel.CamelContext;
> import org.apache.camel.Endpoint;
> import org.apache.camel.impl.DefaultComponent;
> + import org.apache.camel.util.IntrospectionSupport;
>
> +
> /**
> * Defines the <a href="
http://activemq.apache.org/camel/cxf.html">CXF Component</a>
>
> * @version $Revision$
> */
> public class CxfComponent extends DefaultComponent<CxfExchange> {
> +
>
> public CxfComponent() {
> }
> {code}
>
> {code}
> ***************
> *** 18,72 ****
>
> import org.apache.camel.Processor;
> import org.apache.camel.impl.DefaultConsumer;
> import org.apache.cxf.message.Message;
> import org.apache.cxf.transport.Destination;
> import org.apache.cxf.transport.MessageObserver;
> - import org.apache.cxf.transport.local.LocalTransportFactory;
>
> /**
> * A consumer of exchanges for a service in CXF
> *
> * @version $Revision$
> */
> public class CxfConsumer extends DefaultConsumer<CxfExchange> {
> - private CxfEndpoint endpoint;
> - private final LocalTransportFactory transportFactory;
> private Destination destination;
>
> - public CxfConsumer(CxfEndpoint endpoint, Processor processor, LocalTransportFactory transportFactory) {
> super(endpoint, processor);
> this.endpoint = endpoint;
> - this.transportFactory = transportFactory;
> }
>
> @Override
> protected void doStart() throws Exception {
> - super.doStart();
> -
> - destination = transportFactory.getDestination(endpoint.getEndpointInfo());
> - destination.setMessageObserver(new MessageObserver() {
> - public void onMessage(Message message) {
> - incomingCxfMessage(message);
> - }
> - });
> }
>
> @Override
> protected void doStop() throws Exception {
> - if (destination != null) {
> - destination.shutdown();
> - }
> super.doStop();
> }
>
> - protected void incomingCxfMessage(Message message) {
> - try {
> - CxfExchange exchange = endpoint.createExchange(message);
> - getProcessor().process(exchange);
> - } catch (Exception e) {
> - // TODO: what do do if we are getting processing errors from camel?
> - // Shutdown?
> - e.printStackTrace();
> - }
> - }
> }
> --- 18,71 ----
>
> import org.apache.camel.Processor;
> import org.apache.camel.impl.DefaultConsumer;
> + import org.apache.cxf.endpoint.Server;
> + import org.apache.cxf.frontend.ServerFactoryBean;
> import org.apache.cxf.message.Message;
> import org.apache.cxf.transport.Destination;
> import org.apache.cxf.transport.MessageObserver;
>
> +
> /**
> * A consumer of exchanges for a service in CXF
> *
> * @version $Revision$
> */
> public class CxfConsumer extends DefaultConsumer<CxfExchange> {
> + private CxfEndpoint endpoint;
> + private Server server;
> private Destination destination;
>
> + public CxfConsumer(CxfEndpoint endpoint, Processor processor) throws ClassNotFoundException {
> +
> super(endpoint, processor);
> + System.out.println(processor.toString());
> this.endpoint = endpoint;
> + //we setup the interceptors by the endpoint configuration
> + //create server here, now we just use the simple front-end
> + ServerFactoryBean svrBean = new ServerFactoryBean();
> + Class serviceClass = Class.forName(endpoint.getServiceClass());
> + svrBean.setAddress(endpoint.getAddress());
> + svrBean.setServiceClass(serviceClass);
> + if (endpoint.isInvoker()) {
> + System.out.println("setup the invoker ");
> + svrBean.setInvoker(new CamelInvoker(this));
> + }
> + svrBean.setStart(false);
> + server = svrBean.create();
> }
>
> @Override
> protected void doStart() throws Exception {
> + super.doStart();
> +
> + server.start();
> }
>
> @Override
> protected void doStop() throws Exception {
> + server.stop();
> super.doStop();
> }
>
> +
> }
> {code}
>
> {code}
> ***************
> *** 16,53 ****
> */
> package org.apache.camel.component.cxf;
>
> import org.apache.camel.Consumer;
> import org.apache.camel.Processor;
> import org.apache.camel.Producer;
> import org.apache.camel.impl.DefaultEndpoint;
> - import org.apache.cxf.BusException;
> import org.apache.cxf.message.Message;
> - import org.apache.cxf.service.model.EndpointInfo;
> - import org.apache.cxf.transport.local.LocalTransportFactory;
>
> /**
> * Defines the <a href="
http://activemq.apache.org/camel/cxf.html">CXF Endpoint</a>
> *
> * @version $Revision$
> */
> - public class CxfEndpoint extends DefaultEndpoint<CxfExchange> {
> private CxfBinding binding;
> - private final CxfComponent component;
> - private final EndpointInfo endpointInfo;
> private boolean inOut = true;
>
> - public CxfEndpoint(String uri, CxfComponent component, EndpointInfo endpointInfo) {
> super(uri, component);
> - this.component = component;
> - this.endpointInfo = endpointInfo;
> }
> -
> public Producer<CxfExchange> createProducer() throws Exception {
> - return new CxfProducer(this, getLocalTransportFactory());
> }
>
> public Consumer<CxfExchange> createConsumer(Processor processor) throws Exception {
> - return new CxfConsumer(this, processor, getLocalTransportFactory());
> }
>
> public CxfExchange createExchange() {
> --- 16,59 ----
> */
> package org.apache.camel.component.cxf;
>
> + import javax.xml.namespace.QName;
> +
> import org.apache.camel.Consumer;
> import org.apache.camel.Processor;
> import org.apache.camel.Producer;
> import org.apache.camel.impl.DefaultEndpoint;
> + import org.apache.cxf.endpoint.Endpoint;
> import org.apache.cxf.message.Message;
>
> +
> /**
> * Defines the <a href="
http://activemq.apache.org/camel/cxf.html">CXF Endpoint</a>
> *
> * @version $Revision$
> */
> + public class CxfEndpoint extends DefaultEndpoint<CxfExchange> {
> + private final CxfComponent component;
> + private final String address;
> + private String wsdlURL;
> + private String serviceClass;
> private CxfBinding binding;
> + private QName portName;
> + private QName serviceName;
> private boolean inOut = true;
> + private boolean invoker = true;
>
> + public CxfEndpoint(String uri, String address, CxfComponent component) {
> super(uri, component);
> + this.component = component;
> + this.address = address;
> }
> +
> public Producer<CxfExchange> createProducer() throws Exception {
> + return new CxfProducer(this);
> }
>
> public Consumer<CxfExchange> createConsumer(Processor processor) throws Exception {
> + return new CxfConsumer(this, processor);
> }
>
> public CxfExchange createExchange() {
> {code}
>
>
>
>
>> Camel CXF Invoker component support
>> -----------------------------------
>>
>> Key: CAMEL-118
>> URL:
https://issues.apache.org/activemq/browse/CAMEL-118>> Project: Apache Camel
>> Issue Type: Sub-task
>> Components: camel-cxf
>> Reporter: Willem Jiang
>> Fix For: 1.2.0
>>
>> Attachments: cxf.patch, cxf.patch2, filestates, svn-rm.patch
>>
>>
>> CXFProducer holds the CXF client's reference,CXFConsumer holds the CXF server's reference, Now I just wrote a router test which redirect a service request from CXFService A to CXFService B
>> I attached a patch and a svn state out put which would be helpful to verify the files statues
>>
>
>
Locked
