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 reactor-netty-1.0 latest dep tests (#8922)

This commit is contained in:
Lauri Tulmin 2023-07-11 18:48:52 +03:00 committed by GitHub
parent 8815952300
commit fce77cc044
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
instrumentation/reactor/reactor-netty/reactor-netty-1.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/reactornetty/v1_0/TransportConnectorInstrumentation.java
View File

@ -7,6 +7,7 @@ package io.opentelemetry.javaagent.instrumentation.reactornetty.v1_0;
import static io.opentelemetry.javaagent.instrumentation.reactornetty.v1_0.ReactorNettySingletons.connectionInstrumenter;
import static net.bytebuddy.matcher.ElementMatchers.named;
import static net.bytebuddy.matcher.ElementMatchers.namedOneOf;
import static net.bytebuddy.matcher.ElementMatchers.returns;
import static net.bytebuddy.matcher.ElementMatchers.takesArgument;
@ -53,7 +54,13 @@ public class TransportConnectorInstrumentation implements TypeInstrumentation {
transformer.applyAdviceToMethod(
named("doConnect")
.and(takesArgument(0, List.class))
.and(takesArgument(2, named("io.netty.channel.ChannelPromise")))
.and(
takesArgument(
2,
namedOneOf(
"io.netty.channel.ChannelPromise",
// since 1.0.34
"reactor.netty.transport.TransportConnector$MonoChannelPromise")))
.and(takesArgument(3, int.class)),
TransportConnectorInstrumentation.class.getName() + "$ConnectNewAdvice");
}