Skip to content

Commit 4caa06a

Browse files
atsharpmarcingrzejszczak
authored andcommitted
tests
1 parent 00bbb9e commit 4caa06a

File tree

2 files changed

+590
-7
lines changed

2 files changed

+590
-7
lines changed

spring-cloud-sleuth-instrumentation/src/main/java/org/springframework/cloud/sleuth/instrument/async/LazyTraceScheduledThreadPoolExecutor.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -90,8 +90,8 @@ class LazyTraceScheduledThreadPoolExecutor extends ScheduledThreadPoolExecutor {
9090
this.decorateTaskRunnable = ReflectionUtils.findMethod(ScheduledThreadPoolExecutor.class, "decorateTask",
9191
Runnable.class, RunnableScheduledFuture.class);
9292
makeAccessibleIfNotNull(this.decorateTaskRunnable);
93-
this.decorateTaskCallable = ReflectionUtils.findMethod(ScheduledThreadPoolExecutor.class,
94-
"decorateTask", Callable.class, RunnableScheduledFuture.class);
93+
this.decorateTaskCallable = ReflectionUtils.findMethod(ScheduledThreadPoolExecutor.class, "decorateTask",
94+
Callable.class, RunnableScheduledFuture.class);
9595
makeAccessibleIfNotNull(this.decorateTaskCallable);
9696
this.finalize = ReflectionUtils.findMethod(ScheduledThreadPoolExecutor.class, "finalize", null);
9797
makeAccessibleIfNotNull(this.finalize);
@@ -125,8 +125,8 @@ private void makeAccessibleIfNotNull(Method method) {
125125
this.decorateTaskRunnable = ReflectionUtils.findMethod(ScheduledThreadPoolExecutor.class, "decorateTask",
126126
Runnable.class, RunnableScheduledFuture.class);
127127
makeAccessibleIfNotNull(this.decorateTaskRunnable);
128-
this.decorateTaskCallable = ReflectionUtils.findMethod(ScheduledThreadPoolExecutor.class,
129-
"decorateTask", Callable.class, RunnableScheduledFuture.class);
128+
this.decorateTaskCallable = ReflectionUtils.findMethod(ScheduledThreadPoolExecutor.class, "decorateTask",
129+
Callable.class, RunnableScheduledFuture.class);
130130
makeAccessibleIfNotNull(this.decorateTaskCallable);
131131
this.finalize = ReflectionUtils.findMethod(ScheduledThreadPoolExecutor.class, "finalize", null);
132132
makeAccessibleIfNotNull(this.finalize);
@@ -416,7 +416,7 @@ public <T> T invokeAny(Collection<? extends Callable<T>> tasks) throws Interrupt
416416
return this.delegate.invokeAny(wrapCallableCollection(tasks));
417417
}
418418

419-
private <T> Collection<? extends Callable<T>> wrapCallableCollection(Collection<? extends Callable<T>> tasks) {
419+
<T> Collection<? extends Callable<T>> wrapCallableCollection(Collection<? extends Callable<T>> tasks) {
420420
List<Callable<T>> ts = new ArrayList<>();
421421
for (Callable<T> task : tasks) {
422422
if (!(task instanceof TraceCallable)) {

0 commit comments

Comments
 (0)