open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix mongo latest dep test (#14642)

This commit is contained in:
Lauri Tulmin 2025-09-12 16:47:22 +03:00 committed by GitHub
parent 42c5fa13b6
commit 2a05236a56
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
instrumentation/mongo/mongo-4.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/mongo/v4_0/DefaultConnectionPoolTaskInstrumentation.java
View File

@ -34,6 +34,10 @@ public class DefaultConnectionPoolTaskInstrumentation implements TypeInstrumenta
transformer.applyAdviceToMethod( transformer.applyAdviceToMethod(
isConstructor().and(takesArgument(3, Consumer.class)), isConstructor().and(takesArgument(3, Consumer.class)),
this.getClass().getName() + "$TaskArg3Advice"); this.getClass().getName() + "$TaskArg3Advice");
// since 5.6.0
transformer.applyAdviceToMethod(
isConstructor().and(takesArgument(4, Consumer.class)),
this.getClass().getName() + "$TaskArg4Advice");
} }
@SuppressWarnings("unused") @SuppressWarnings("unused")
@ -55,4 +59,14 @@ public class DefaultConnectionPoolTaskInstrumentation implements TypeInstrumenta
action = new TaskWrapper(Java8BytecodeBridge.currentContext(), action); action = new TaskWrapper(Java8BytecodeBridge.currentContext(), action);
} }
} }
@SuppressWarnings("unused")
public static class TaskArg4Advice {
@Advice.OnMethodEnter(suppress = Throwable.class)
public static void wrapCallback(
@Advice.Argument(value = 4, readOnly = false) Consumer<Object> action) {
action = new TaskWrapper(Java8BytecodeBridge.currentContext(), action);
}
}
} }