diff --git a/instrumentation/google-http-client-1.19/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/googlehttpclient/GoogleHttpClientAsyncTest.java b/instrumentation/google-http-client-1.19/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/googlehttpclient/GoogleHttpClientAsyncTest.java index 548af9757b..7bc1aed75c 100644 --- a/instrumentation/google-http-client-1.19/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/googlehttpclient/GoogleHttpClientAsyncTest.java +++ b/instrumentation/google-http-client-1.19/javaagent/src/test/java/io/opentelemetry/javaagent/instrumentation/googlehttpclient/GoogleHttpClientAsyncTest.java @@ -7,11 +7,21 @@ package io.opentelemetry.javaagent.instrumentation.googlehttpclient; import com.google.api.client.http.HttpRequest; import com.google.api.client.http.HttpResponse; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; +import org.junit.jupiter.api.AfterAll; class GoogleHttpClientAsyncTest extends AbstractGoogleHttpClientTest { + private final ExecutorService executor = Executors.newFixedThreadPool(4); + + @AfterAll + void tearDown() { + executor.shutdown(); + } + @Override protected HttpResponse sendRequest(HttpRequest request) throws Exception { - return request.executeAsync().get(); + return request.executeAsync(executor).get(); } }