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

    Switchyard and Camel Transparent Proxy doesn't propagate SOAP header

    Miguel Fernández Martínez Newbie

      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!!!