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

Reply via email to