Hi the wssec.xml and client class are used as client to invoke the camel route. You can setup the cxfEndpoint in the same way as the test showed in the spring xml way.
If you want to setup the cxfEndpoint in programical way, you could just consider to implement CxfEndpointConfigurer[1] yourself to setup the output interceptors in the method of void configure(AbstractWSDLBasedEndpointFactory factoryBean); You can setup the CxfEndpointConfigure on the cxfEndpoint by setup the cxf endpoint url just like this "cxf://xxx?cxfEndpointConfigure=#myConfigure" and you need to put the instance of CxfEndpointConfigure into the CamelContext registry. [1]https://github.com/apache/camel/blob/master/components/camel-cxf/src/main/java/org/apache/camel/component/cxf/CxfEndpointConfigurer.java Willem Jiang Twitter: willemjiang Weibo: 姜宁willem On Thu, Jan 10, 2019 at 5:38 AM Isaiah Inuwa <isaiah.in...@moody.edu> wrote: > > Hello Willem, > > Thank you for your response. > > Perhaps this could be my ignorance with Spring and CXF, but do it seems that > the link you gave shows how to configure the incoming service to accept a > username token rather than the outgoing service. Would either the wssec.xml > file [1] or the Client [1] class in that same package be what I need? > > I have added the spring-boot-starter to my pom.xml and registered my > RouteBuilder class as a Component so Spring will automatically run it on > startup successfully. However, I don't know how to get the bean definitions > from Spring into the Camel route. If I create the CXF endpoint or client bean > in Spring, how do I get Camel to reference it? Sorry if it's a stupid > question. > > [1] > https://github.com/apache/camel/blob/master/components/camel-cxf/src/test/resources/org/apache/camel/component/cxf/wssecurity/client/wssec.xml > [2] > https://github.com/apache/camel/blob/master/components/camel-cxf/src/test/java/org/apache/camel/component/cxf/wssecurity/client/Client.java > > Isaiah Inuwa > > -----Original Message----- > From: Willem Jiang <willem.ji...@gmail.com> > Sent: Tuesday, January 8, 2019 8:15 PM > To: users@camel.apache.org > Subject: Re: Help Accessing Remote SOAP Service with Authentication via CXF > > Hi, > > I think you may need find the right moment to setup the CXFEndpoint. > It could be meaningless if the camel route is loaded and the CXFConsumer is > created. > Can you try to use the Spring configuration to setup the cxfEndpoint this > way[1]? > [1] > https://github.com/apache/camel/blob/master/components/camel-cxf/src/test/resources/org/apache/camel/component/cxf/wssecurity/camel/camel-context.xml > > Willem Jiang > > Twitter: willemjiang > Weibo: 姜宁willem > > On Wed, Jan 9, 2019 at 5:59 AM Isaiah Inuwa <isaiah.in...@moody.edu> wrote: > > > > Hello everyone, > > > > This is my first foray into Camel. I am looking into alternatives to > > MuleSoft ever since they released Mule 4.0 and dropped tooling for the > > Community Edition. > > > > My main question is how to configure a CXF client in Camel with > > UsernameToken authentication. (I have more questions besides this, but > > I'll start here.) My task is to synchronize contact information > > between our local system and a third-party service using SOAP. Here is the > > basic flow: > > > > - Read JSON objects from RabbitMQ > > - Convert Objects to JAXB Objects required for third-party service > > - POST objects to SOAP service > > > > I am able to read from the RabbitMQ instance, but I am confused on how > > to use CXF to access the remote service. Most of the information I see > > concerns using CXF as a service rather than as a client. Here is what I > > have so far: > > > > // Application.java > > public class Application { > > > > private static CamelContext context; > > public static void main(String args[]) throws Exception { > > context = new DefaultCamelContext(); > > context.addRoutes(new MyRouteBuilder()); > > context.start(); > > } > > } > > > > //MyRouteBuilder.java > > public class MyRouteBuilder extends RouteBuilder { > > > > @Override > > public void configure() throws Exception { > > > > from("rabbitmq:...") > > .to("direct:start"); > > > > JsonDataFormat jsonDataFormat = new JsonDataFormat(); > > jsonDataFormat.setLibrary(JsonLibrary.Jackson); > > jsonDataFormat.setUnmarshalType(ContactInfo.class); > > > > from("direct:start") > > .unmarshal(jsonDataFormat) > > .process(new ContactInfoToOSCContactProcessor()) // returns a JAXB > > Object generated by service WSDL > > .choice() > > ... > > .to("direct:updatecontact"); > > > > String contactServiceUri = > > "cxf://https://thirdparty.example.com/ContactService"; > > + "?serviceClass=" + ContactService.class.getCanonicalName() > > + "&wsdlURL=contactservice.wsdl"; > > > > from("direct:updatecontact") > > .setHeader("operationName", constant("updateContact")) > > .to(contactServiceUri) > > .unmarshal(soapDF) > > .log("The response was ${body[0]}"); > > } > > } > > > > > > > > From here, I get an error: > > > org.apache.cxf.ws.policy.PolicyException: A encryption username needs to > > > be declared. > > > > Makes sense, because I need to set the UsernameToken for the request. > > I am pretty sure that with CXF, I need to add an outgoing interceptors > > like this, so I tried creating a CXF Endpoint from the Camel Context and > > modifying it there: > > > > ... > > CxfEndpoint contactServiceEndpoint = (CxfEndpoint) > > getContext().getEndpoint(contactServiceUri); > > Map<String,Object> outProps = new HashMap<>(); > > outProps.put(WSHandlerConstants.ACTION, WSHandlerConstants.USERNAME_TOKEN > > + " " + WSHandlerConstants.TIMESTAMP); > > outProps.put(WSHandlerConstants.PASSWORD_TYPE, "PasswordDigest"); > > outProps.put(WSHandlerConstants.USER, "psadmin"); > > outProps.put(WSHandlerConstants.PW_CALLBACK_CLASS, > > UTPasswordCallback.class.getName()); > > WSS4JOutInterceptor outInterceptor = new WSS4JOutInterceptor(outProps); > > contactServiceEndpoint.getOutInterceptors().add(outInterceptor); > > > > ... > > > > from("direct:updatecontact") > > .setHeader("operationName", constant("updateContact")) > > .to(contactServiceEndpoint) > > .unmarshal(soapDF) > > .log("The response was ${body[0]}"); > > > > > > but I get the same error. So I have two questions: > > 1) Is using the cxf: component in this way the canonical way of accessing a > > remote client? > > 2) How do I configure a CXF client endpoint with authentication? > > > > I hope that shows what I am talking about; trying to learn Camel and > > CXF at the same time is confusing. (Note that I am not using Spring in > > my example since I haven't had much experience with it yet am trying to > > learn one thing at a time. > > But if using Spring in this case is the better way to go, then I'm all > > for it.) > > > > Thank you in advance for your help! > > > > Isaiah Inuwa
