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
