Spring-Integration-DSL和Soap服务Soap头没有被调用

Question

我想调用一个肥皂服务与春天集成DSL，有一些自定义头需要添加。

构建marshellingoutboundgateway。尝试覆盖DefaultSoapHeaderMapper，但没有重写的方法被调用。

试图构建这样的事情。

<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/"> 
    <soapenv:Header> 
     <ObjectType34 > 

     </ObjectType34> 
    </soapenv:Header> 
    <soapenv:Body> 
     <ObjectType12 > 

     </ObjectType12> 
    </soapenv:Body> 
</soapenv:Envelope> 

有一个样本：https://github.com/spring-projects/spring-integration/blob/master/src/reference/asciidoc/ws.adoc

貌似只有在5.0

发布详细信息代码可用。

任何见解都会有所帮助。

@Configuration 
@SpringBootApplication 
@IntegrationComponentScan 
@EnableIntegration 
public class Application { 
    public static void main(String[] args) { 
     ConfigurableApplicationContext ctx = SpringApplication.run(Application.class, args); 
     Info Info = ctx.getBean(Info.class); 

     //Constructing request Payload 
     ObjectType12 getInfoType = new ObjectFactory().ObjectType12(); 
     JAXBElement<GetInfoType> getInfoTypeJAXBElement = new ObjectFactory().createGetInfo(getInfoType); 
     JAXBElement<GetInfoResponseType> getInfoResponseType = Info.getInfo(getInfoTypeJAXBElement); 
     System.out.println(getInfoResponseType.getName()); 
     ctx.close(); 
    } 

    @MessagingGateway 
    public interface Info { 

     @Gateway(requestChannel = "convert.input") 
     JAXBElement<GetInfoResponseType> getInfo(JAXBElement<GetInfoType> InfoType); 

    } 

    @Bean 
    public IntegrationFlow convert() { 

     StringResult result = new StringResult(); 

     return flow -> flow 
       .wireTap(f -> f.<JAXBElement, String>transform(ele -> { 
        jaxb2Marshaller().marshal(ele, result); 
        return result.toString(); 
       }).log()) 
       .handle(endpoint()); 
    } 

    @Bean 
    public Jaxb2Marshaller jaxb2Marshaller() { 
     Jaxb2Marshaller marshaller = new Jaxb2Marshaller(); 
     marshaller.setPackagesToScan("org.abc", "com.abc"); 
     return marshaller; 
    } 

    @Bean 
    public MarshallingWebServiceOutboundGateway endpoint() { 
     MarshallingWebServiceOutboundGateway gateway = new MarshallingWebServiceOutboundGateway("https://example.com/v1", jaxb2Marshaller(), jaxb2Marshaller()); 

     gateway.setHeaderMapper(new DefaultSoapHeaderMapper() { 

      @Override 
      protected void populateUserDefinedHeader(String headerName, Object headerValue, SoapMessage target) { 
       super.populateUserDefinedHeader("Content-Type", "application/soap+xml", target); 
      } 

      @Override 
      protected void populateStandardHeaders(Map<String, Object> headers, SoapMessage target) { 
       headers.put(WebServiceHeaders.SOAP_ACTION, 
         "http://www.example.com/SOAUI/ServiceHeader/V4"); 
       super.populateStandardHeaders(headers, target); 
      } 

      @Override 
      public void fromHeadersToRequest(MessageHeaders headers, SoapMessage target) { 
       SaajSoapMessage targetMessage = (SaajSoapMessage) target; 
       SoapHeader header = targetMessage.getEnvelope().getHeader(); 
       //Constructing SOAP Header 

       JAXBElement<ObjectType34> trackingHdrTypeJAXBElement = ObjectFactory().createHdr(ObjectType34); 
       jaxb2Marshaller().marshal(trackingHdrTypeJAXBElement, header.getResult()); 
       System.out.println(header.getResult()); 
      } 

      @Override 
      public void setRequestHeaderNames(String... requestHeaderNames) { 
       super.setRequestHeaderNames("*"); 
      } 
     }); 
     gateway.setMessageFactory(new SaajSoapMessageFactory() { 

      @Override 
      public void setSoapVersion(SoapVersion version) { 
       super.setSoapVersion(SoapVersion.SOAP_11); 
      } 
     }); 
     return gateway; 
    } 
} 

Answer 1

UPDATE：修改代码

@Bean 
    public DefaultSoapHeaderMapper headerMapper11() { 

     return new DefaultSoapHeaderMapper() { 
      @Override 
      public void fromHeadersToRequest(MessageHeaders headers, SoapMessage target) { 
       SaajSoapMessage targetMessage = (SaajSoapMessage) target; 
       SoapHeader header = targetMessage.getEnvelope().getHeader(); 
       //Constructing SOAP Header 
       JAXBElement<ObjectType34> trackingHdrTypeJAXBElement = ObjectFactory().createHdr(ObjectType34); 
       jaxb2Marshaller().marshal(trackingHdrTypeJAXBElement, header.getResult()); 
       super.fromHeadersToRequest(headers, target); 
      } 
     }; 

    } 

以及使用该方法调用设置的标头：

gateway.setHeaderMapper(headerMapper11()); 

现在重写的方法获取调用并且具有头部为好。

代码现在按预期工作。