fix missing scope close

SylvainJuge · SylvainJuge · commit 6c6e25a610f8 · 2025-09-30T21:23:38.000+02:00
diff --git a/instrumentation/opensearch/opensearch-rest-1.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/opensearch/rest/v1_0/RestClientInstrumentation.java b/instrumentation/opensearch/opensearch-rest-1.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/opensearch/rest/v1_0/RestClientInstrumentation.java
@@ -94,6 +94,7 @@ public void endWithResponse(@Nullable Response response, @Nullable Throwable thr
     }
 
     public void endWithListener(@Nullable Throwable throwable) {
+      scope.close();
       if (throwable != null) {
         instrumenter().end(context, otelRequest, null, throwable);
       }
diff --git a/instrumentation/opensearch/opensearch-rest-3.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/opensearch/rest/v3_0/RestClientInstrumentation.java b/instrumentation/opensearch/opensearch-rest-3.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/opensearch/rest/v3_0/RestClientInstrumentation.java
@@ -94,6 +94,7 @@ public void endWithResponse(@Nullable Response response, @Nullable Throwable thr
     }
 
     public void endWithListener(@Nullable Throwable throwable) {
+      scope.close();
       if (throwable != null) {
         instrumenter().end(context, otelRequest, null, throwable);
       }

Original file line number	Diff line number	Diff line change
`@@ -94,6 +94,7 @@ public void endWithResponse(@Nullable Response response, @Nullable Throwable thr`
`94`	`94`	`}`
`95`	`95`
`96`	`96`	`public void endWithListener(@Nullable Throwable throwable) {`
	`97`	`+ scope.close();`
`97`	`98`	`if (throwable != null) {`
`98`	`99`	`instrumenter().end(context, otelRequest, null, throwable);`
`99`	`100`	`}`