From 71a141a70227ea85a48fc51b23cadcc6d134e963 Mon Sep 17 00:00:00 2001 From: Marcin Grzejszczak Date: Fri, 9 Feb 2024 14:00:33 +0100 Subject: [PATCH] TraceReactorAutoConfiguration.HooksRefresher improper queue decoration fixes gh-2318 --- .../instrument/reactor/TraceReactorAutoConfiguration.java | 1 + 1 file changed, 1 insertion(+) diff --git a/spring-cloud-sleuth-autoconfigure/src/main/java/org/springframework/cloud/sleuth/autoconfig/instrument/reactor/TraceReactorAutoConfiguration.java b/spring-cloud-sleuth-autoconfigure/src/main/java/org/springframework/cloud/sleuth/autoconfig/instrument/reactor/TraceReactorAutoConfiguration.java index 5c250e6d9..d0eaf3a18 100644 --- a/spring-cloud-sleuth-autoconfigure/src/main/java/org/springframework/cloud/sleuth/autoconfig/instrument/reactor/TraceReactorAutoConfiguration.java +++ b/spring-cloud-sleuth-autoconfigure/src/main/java/org/springframework/cloud/sleuth/autoconfig/instrument/reactor/TraceReactorAutoConfiguration.java @@ -149,6 +149,7 @@ class HooksRefresher implements ApplicationListener Schedulers.onScheduleHook(TraceReactorAutoConfiguration.SLEUTH_REACTOR_EXECUTOR_SERVICE_KEY, ReactorSleuth.scopePassingOnScheduleHook(this.context)); } + break; case DECORATE_ON_EACH: if (log.isTraceEnabled()) { log.trace("Decorating onEach operator instrumentation");