TraceReactorAutoConfiguration.HooksRefresher improper queue decoration

marcingrzejszczak · marcingrzejszczak · commit 71a141a70227 · 2024-02-09T14:00:33.000+01:00
fixes gh-2318
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
@@ -149,6 +149,7 @@ public void onApplicationEvent(RefreshScopeRefreshedEvent event) {
 				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");

Original file line number	Diff line number	Diff line change
`@@ -149,6 +149,7 @@ public void onApplicationEvent(RefreshScopeRefreshedEvent event) {`
`149`	`149`	`Schedulers.onScheduleHook(TraceReactorAutoConfiguration.SLEUTH_REACTOR_EXECUTOR_SERVICE_KEY,`
`150`	`150`	`ReactorSleuth.scopePassingOnScheduleHook(this.context));`
`151`	`151`	`}`
	`152`	`+ break;`
`152`	`153`	`case DECORATE_ON_EACH:`
`153`	`154`	`if (log.isTraceEnabled()) {`
`154`	`155`	`log.trace("Decorating onEach operator instrumentation");`