Làm thế nào để sử dụng Spring Autowired trong bộ chặn đánh dấu cxf tùy chỉnh?

Question

tôi dường như chạy vào một vấn đề nhỏ khi sử dụng @Autowired thành một bộ chặn đánh chặn cxf tùy chỉnh. Trường hợp sử dụng của tôi là tôi muốn ghi lại các tin nhắn xà phòng và gửi chúng bằng AMQP tới một hệ thống khác. Quá trình này hoạt động cho các dịch vụ thông thường, vv .. Nhưng bất cứ điều gì tôi làm, các thuộc tính cần thiết không nhận được autowired và ở lại null.

Tôi đã kiểm tra nhật ký Spring DI và bối cảnh được quét và chọn, vì vậy tôi đang thiếu gì?

Điều này có thể thực hiện được trong các thiết bị đánh chặn CXF không?

@Component 
public class LogInInterceptor extends AbstractSoapInterceptor { 

    private @Value("#{rabbitMQProperties['rabbitmq.binding.log.soap']}") 
    String binding; 

    @Autowired 
    AmqpTemplate amqpTemplate; 

    public LogInInterceptor() { 
     super(Phase.RECEIVE); 
    } 

    @Override 
    public void handleMessage(SoapMessage soapMessage) throws Fault { 
     logIt(soapMessage); 
    } 

    private void logIt(SoapMessage message) throws Fault { 
     // rest of the code omitted...!!!  
     amqpTemplate.convertAndSend(binding, buffer.toString()); 
    } 

} 

Answer 1

Bạn không thể trộn lẫn @InInterceptors (một chú thích CXF) và@Component (một chú thích mùa xuân). Điều đó sẽ tạo ra hai trường hợp riêng biệt của interceptor của bạn: một trong những phụ thuộc của nó đang được tiêm bởi Spring, và một trong những được tạo ra bởi CXF. (Bạn đang cung cấp tên lớp trong @InInterceptors chú thích, không phải là một ID đậu, vì vậy CXF không có cách nào để biết rằng bạn đã tạo ra một thể hiện trong bối cảnh mùa xuân.)

Tháo @InInterceptors chú thích và, ngoài các component scan :

<context:component-scan base-package="org.example.config"/> 

bạn cũng cần một cái gì đó như thế này trong bối cảnh ứng dụng của bạn:

<jaxws:endpoint id="myWebService" address="/MyWebService"> 
    <jaxws:inInterceptors> 
     <ref bean="myInInterceptor" /> 
    </jaxws:inInterceptors> 
</jaxws:endpoint> 

Answer 2

tôi biết đây là một câu hỏi cũ, nhưng Jonathan W của câu trả lời giúp tôi và tôi muốn thêm cho nó.

Đây là cách tôi đã chặn tùy chỉnh và @Autowired để làm việc với mùa xuân Boot 1.3.1:

http://cxf.apache.org/docs/jax-ws-configuration.html

import java.util.Arrays; 

import javax.jws.WebService; 

import org.apache.cxf.Bus; 
import org.apache.cxf.interceptor.LoggingInInterceptor; 
import org.apache.cxf.jaxws.EndpointImpl; 
import org.apache.cxf.transport.servlet.CXFServlet; 
import org.springframework.beans.factory.annotation.Autowired; 
import org.springframework.boot.SpringApplication; 
import org.springframework.boot.autoconfigure.EnableAutoConfiguration; 
import org.springframework.boot.builder.SpringApplicationBuilder; 
import org.springframework.boot.context.embedded.ServletRegistrationBean; 
import org.springframework.boot.context.web.SpringBootServletInitializer; 
import org.springframework.context.ApplicationContext; 
import org.springframework.context.annotation.Bean; 
import org.springframework.context.annotation.Configuration; 
import org.springframework.context.annotation.ImportResource; 

@Configuration 
@EnableAutoConfiguration 
@ImportResource({ "classpath:META-INF/cxf/cxf.xml" }) 
public class Application extends SpringBootServletInitializer { 

    @Autowired 
    private ApplicationContext applicationContext; 

    @Autowired 
    private MyInterceptor myInterceptor; 

    @Autowired 
    private HelloWorldImpl helloWorldImpl; 

    public static void main(String[] args) { 
     SpringApplication.run(Application.class, args); 
    } 

    // Replaces the need for web.xml 
    @Bean 
    public ServletRegistrationBean servletRegistrationBean(ApplicationContext context) { 
     return new ServletRegistrationBean(new CXFServlet(), "/api/*"); 
    } 

    // Replaces cxf-servlet.xml 
    @Bean 
    // <jaxws:endpoint id="helloWorld" implementor="demo.spring.service.HelloWorldImpl" address="/HelloWorld"/> 
    public EndpointImpl helloService() { 
     Bus bus = (Bus) applicationContext.getBean(Bus.DEFAULT_BUS_ID); 
     EndpointImpl endpoint = new EndpointImpl(bus, helloWorldImpl); 

     // Set interceptors here 
     endpoint.setInInterceptors(Arrays.asList(myInterceptor)); 

     endpoint.publish("/hello"); 
     return endpoint; 
    } 


    // Used when deploying to a standalone servlet container, i.e. tomcat 
    @Override 
    protected SpringApplicationBuilder configure(SpringApplicationBuilder application) { 
     return application.sources(Application.class); 
    } 

    // Web service endpoint 
    @WebService(endpointInterface = "demo.spring.service.HelloWorld") 
    //@InInterceptors not defined here 
    public static class HelloWorldImpl { 

    } 

    public static class MyInterceptor extends LoggingInInterceptor { 
     // @Autowired works here 
    } 

}