Merge branch '1.3.x'
This commit is contained in:
@@ -39,13 +39,16 @@ public class TraceReactorAutoConfiguration {
|
||||
@Configuration
|
||||
@ConditionalOnBean(Tracing.class)
|
||||
static class TraceReactorConfiguration {
|
||||
|
||||
private static final String SLEUTH_TRACE_REACTOR_KEY = TraceReactorConfiguration.class.getName();
|
||||
|
||||
@Autowired Tracing tracing;
|
||||
@Autowired BeanFactory beanFactory;
|
||||
@Autowired LastOperatorWrapper lastOperatorWrapper;
|
||||
|
||||
@Bean
|
||||
@ConditionalOnNotWebApplication LastOperatorWrapper spanOperator() {
|
||||
return tracer -> Hooks.onLastOperator(ReactorSleuth.spanOperator(tracer));
|
||||
return tracer -> Hooks.onLastOperator(SLEUTH_TRACE_REACTOR_KEY, ReactorSleuth.spanOperator(tracer));
|
||||
}
|
||||
|
||||
@Bean
|
||||
|
||||
@@ -210,7 +210,6 @@ public class SpanSubscriberTests {
|
||||
}
|
||||
|
||||
@AfterClass
|
||||
@BeforeClass
|
||||
public static void cleanup() {
|
||||
Hooks.resetOnLastOperator();
|
||||
Schedulers.resetFactory();
|
||||
|
||||
Reference in New Issue
Block a user