diff --git a/instrumentation/jetty/jetty-11.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/jetty/v11_0/Jetty11HandlerAdvice.java b/instrumentation/jetty/jetty-11.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/jetty/v11_0/Jetty11HandlerAdvice.java index 6e4d29b99cad..dbefc77c1214 100644 --- a/instrumentation/jetty/jetty-11.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/jetty/v11_0/Jetty11HandlerAdvice.java +++ b/instrumentation/jetty/jetty-11.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/jetty/v11_0/Jetty11HandlerAdvice.java @@ -19,7 +19,8 @@ public class Jetty11HandlerAdvice { @Advice.OnMethodEnter(suppress = Throwable.class) public static void onEnter( @Advice.This Object source, - @Advice.Argument(value = 2, readOnly = false) HttpServletRequest request, + @Advice.Argument(2) HttpServletRequest request, + @Advice.Argument(3) HttpServletResponse response, @Advice.Local("otelContext") Context context, @Advice.Local("otelScope") Scope scope) { @@ -31,6 +32,8 @@ public static void onEnter( context = tracer().startServerSpan(request); scope = context.makeCurrent(); + + tracer().setAsyncListenerResponse(request, response); } @Advice.OnMethodExit(onThrowable = Throwable.class, suppress = Throwable.class) diff --git a/instrumentation/jetty/jetty-8.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/jetty/v8_0/Jetty8HandlerAdvice.java b/instrumentation/jetty/jetty-8.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/jetty/v8_0/Jetty8HandlerAdvice.java index 7f8e1a48f4b7..d89793b54516 100644 --- a/instrumentation/jetty/jetty-8.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/jetty/v8_0/Jetty8HandlerAdvice.java +++ b/instrumentation/jetty/jetty-8.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/jetty/v8_0/Jetty8HandlerAdvice.java @@ -19,7 +19,8 @@ public class Jetty8HandlerAdvice { @Advice.OnMethodEnter(suppress = Throwable.class) public static void onEnter( @Advice.This Object source, - @Advice.Argument(value = 2, readOnly = false) HttpServletRequest request, + @Advice.Argument(2) HttpServletRequest request, + @Advice.Argument(3) HttpServletResponse response, @Advice.Local("otelContext") Context context, @Advice.Local("otelScope") Scope scope) { @@ -31,6 +32,8 @@ public static void onEnter( context = tracer().startServerSpan(request); scope = context.makeCurrent(); + + tracer().setAsyncListenerResponse(request, response); } @Advice.OnMethodExit(onThrowable = Throwable.class, suppress = Throwable.class)