修改注入变量

parent ea766c1e
...@@ -50,18 +50,17 @@ import java.util.List; ...@@ -50,18 +50,17 @@ import java.util.List;
@AutoConfigureOrder @AutoConfigureOrder
@EnableWebMvc @EnableWebMvc
@EnableConfigurationProperties( BraveProperties.class ) @EnableConfigurationProperties( BraveProperties.class )
@Import( { @Import( { TracingClientHttpRequestInterceptor.class, SpanCustomizingAsyncHandlerInterceptor.class } )
TracingClientHttpRequestInterceptor.class,
SpanCustomizingAsyncHandlerInterceptor.class} )
public class BraveAutoConfiguration extends WebMvcConfigurerAdapter { public class BraveAutoConfiguration extends WebMvcConfigurerAdapter {
@Autowired @Autowired
private BraveProperties braveProperties; private BraveProperties braveProperties;
@Autowired @Autowired
SpanCustomizingAsyncHandlerInterceptor spanCustomizingAsyncHandlerInterceptor; private TracingClientHttpRequestInterceptor clientInterceptor;
@Autowired @Autowired
TracingClientHttpRequestInterceptor clientInterceptor; private SpanCustomizingAsyncHandlerInterceptor spanCustomizingAsyncHandlerInterceptor;
@Bean @Bean
Sender sender() { Sender sender() {
...@@ -101,7 +100,7 @@ public class BraveAutoConfiguration extends WebMvcConfigurerAdapter { ...@@ -101,7 +100,7 @@ public class BraveAutoConfiguration extends WebMvcConfigurerAdapter {
} }
@Bean( name = "techOkHttpClient" ) @Bean( name = "techOkHttpClient" )
public OkHttpClient httpClient(HttpTracing httpTracing) { public OkHttpClient okHttpClient(HttpTracing httpTracing) {
log.info("注册OkHttpClient"); log.info("注册OkHttpClient");
return new OkHttpClient.Builder() return new OkHttpClient.Builder()
.dispatcher(new Dispatcher(httpTracing.tracing().currentTraceContext().executorService(new Dispatcher().executorService()))) .dispatcher(new Dispatcher(httpTracing.tracing().currentTraceContext().executorService(new Dispatcher().executorService())))
...@@ -113,23 +112,22 @@ public class BraveAutoConfiguration extends WebMvcConfigurerAdapter { ...@@ -113,23 +112,22 @@ public class BraveAutoConfiguration extends WebMvcConfigurerAdapter {
* *
* @return * @return
*/ */
@Bean @Bean( name = "DelegatingTracingFilter" )
public Filter delegatingTracingFilter() { public Filter delegatingTracingFilter() {
return new DelegatingTracingFilter(); return new DelegatingTracingFilter();
} }
@Bean @Bean
public FilterRegistrationBean someFilterRegistration(Filter delegatingTracingFilter) { public FilterRegistrationBean someFilterRegistration() {
log.info("添加DelegatingTracingFilter");
FilterRegistrationBean registration = new FilterRegistrationBean(); FilterRegistrationBean registration = new FilterRegistrationBean();
registration.setFilter(delegatingTracingFilter); registration.setFilter(delegatingTracingFilter());
registration.addUrlPatterns("/*"); registration.addUrlPatterns("/*");
registration.setName("DelegatingTracingFilter"); registration.setName("DelegatingTracingFilter");
return registration; return registration;
} }
/** /** adds tracing to the application-defined rest template */
* adds tracing to the application-defined rest template
*/
@PostConstruct @PostConstruct
public void init() { public void init() {
log.info("添加restTemplate拦截器"); log.info("添加restTemplate拦截器");
...@@ -145,6 +143,7 @@ public class BraveAutoConfiguration extends WebMvcConfigurerAdapter { ...@@ -145,6 +143,7 @@ public class BraveAutoConfiguration extends WebMvcConfigurerAdapter {
log.info("添加webmvc拦截器"); log.info("添加webmvc拦截器");
registry.addInterceptor(spanCustomizingAsyncHandlerInterceptor); registry.addInterceptor(spanCustomizingAsyncHandlerInterceptor);
} }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment