6 Replies Latest reply on Feb 10, 2015 1:29 AM by tadayosi

    Switchyard and Camel Transparent Proxy doesn't propagate SOAP header

    mfernandezmartinez
    mfernandezmartinez Aug 1, 2014 6:11 AM

      Hi!!

      I'm trying to create a transparent proxy with Switchyard. The idea is having a "promoted" service exposed by Switchyard. Calls to this webservice will be redirected with Camel to a service reference. Service reference (proxified service) and promoted service have the same WSDL.

      The problem is that the SOAP calls that the user does contains a custom token in the SOAP Envelope Header that it is NOT propagated. How can I solve that?

      SOAP Call Example (User->Propagated Service):

      <soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:ser="http://service.test/">
      

         <soapenv:Header>
      

         <token>foo</token>
      

         </soapenv:Header>
      

         <soapenv:Body>
      

            <ser:readSomethings>
      

               <something>
      

               </something>
      

            </ser:readSomethings>
      

         </soapenv:Body>
      

      </soapenv:Envelope>

      SOAP Call that Switchyard does to the "proxified" service (It doesn't contain the token!!):

      <SOAP-ENV:Envelope xmlns:SOAP-ENV=\"http://schemas.xmlsoap.org/soap/envelope/\">
      

         <SOAP-ENV:Header/>
      

         <SOAP-ENV:Body>
      

           <ser:readSomethings xmlns:ser=\"http://service.test/\">
      

             <something></something>
      

           </ser:readSomethings>
      

         </SOAP-ENV:Body>
      

      </SOAP-ENV:Envelope>

      switchyard.xml:

      <?xml version="1.0" encoding="ASCII"?>
      <switchyard xmlns="urn:switchyard-config:switchyard:1.0" xmlns:bean="urn:switchyard-component-bean:config:1.0" xmlns:camel="urn:switchyard-component-camel:config:1.0" xmlns:sca="http://docs.oasis-open.org/ns/opencsa/sca/200912" xmlns:soap="urn:switchyard-component-soap:config:1.0" name="SomethingService" targetNamespace="urn:my.company.something:SomethingService:1.0">
              <sca:composite name="SomethingService" targetNamespace="urn:my.company.something:SomethingService:1.0">
               <sca:service name="PromotedProxyService" promote="ProxyService/ProxyService">
               <soap:binding.soap>
               <soap:contextMapper includes=".*"/>
               <soap:wsdl>META-INF/SomethingWS.wsdl</soap:wsdl>
               <soap:socketAddr>:${jettyPort}</soap:socketAddr>
               <soap:contextPath>SomethingService</soap:contextPath>
               </soap:binding.soap>
               </sca:service>
               <sca:reference name="ProxifiedService" multiplicity="0..1" promote="ProxyService/ProxifiedService">
               <soap:binding.soap>
               <soap:contextMapper includes=".*"/>
               <soap:wsdl>META-INF/SomethingWS.wsdl</soap:wsdl>
               <soap:endpointAddress>http://IP:8080/ws_admin/SomethingWS</soap:endpointAddress>
               </soap:binding.soap>
               </sca:reference>
               <sca:component name="ProxyService">
               <camel:implementation.camel>
               <camel:java class="my.company.something.RouterCamel"/>
               </camel:implementation.camel>
               <sca:service name="ProxyService">
               <sca:interface.wsdl interface="META-INF/SomethingWS.wsdl#wsdl.porttype(SomethingWS)"/>
               </sca:service>
               <sca:reference name="ProxifiedService">
               <sca:interface.wsdl interface="META-INF/SomethingWS.wsdl#wsdl.porttype(SomethingWS)"/>
               </sca:reference>
               </sca:component>
              </sca:composite>
              <domain>
               <properties>
               <property name="org.switchyard.handlers.messageTrace.enabled" value="true"/>
               </properties>
              </domain>
      </switchyard>

      RouterCamel.java

      public class RouterCamel extends org.apache.camel.builder.RouteBuilder{
      

       
      

       
      

          public void configure() {
      

              org.apache.camel.Processor myProc = new org.apache.camel.Processor(){
      

                  public void process(org.apache.camel.Exchange exchange) throws Exception {
      

                      System.out.println("------------------------------ ENTRO\n\n\n\n");
      

                      String body = exchange.getIn().getBody(String.class);
      

                      // change the message to say Hello
      

                      System.out.println("\n\n\n\n------------------------------ BODY: " + body);
      

                      exchange.getOut().setBody(body);
      

                      // copy headers from IN to OUT to propagate them
      

                      System.out.println("Header in values:");
      

                      for(Entry<String, Object> header: exchange.getIn().getHeaders().entrySet()){
      

                          System.out.println("Header: " +  header.getKey() + " Value: " + header.getValue());
      

                      }
      

                      exchange.getOut().setHeaders(exchange.getIn().getHeaders());
      

                      System.out.println("Header out values:");
      

                      for(Entry<String, Object> header: exchange.getOut().getHeaders().entrySet()){
      

                          System.out.println("Header: " +  header.getKey() + " Value: " + header.getValue());
      

                      }
      

                  }
      

              };
      

            // Define routing rules here:
      

            from("switchyard://ProxyService").process(myProc).to("switchyard://ProxifiedService");
      

          }
      

      }

      Thank you!!!