@@ -10,6 +10,7 @@ import com.intellij.openapi.components.service
1010import com.intellij.openapi.diagnostic.thisLogger
1111import com.intellij.openapi.util.SystemInfoRt
1212import com.intellij.serviceContainer.NonInjectable
13+ import com.intellij.util.io.HttpRequests
1314import io.opentelemetry.api.common.AttributeKey
1415import io.opentelemetry.api.common.Attributes
1516import io.opentelemetry.api.trace.propagation.W3CTraceContextPropagator
@@ -25,16 +26,14 @@ import io.opentelemetry.sdk.trace.SpanProcessor
2526import kotlinx.coroutines.CancellationException
2627import kotlinx.coroutines.CoroutineScope
2728import kotlinx.coroutines.launch
28- import org.apache.http.client.methods.HttpPost
29- import org.apache.http.entity.ByteArrayEntity
30- import org.apache.http.impl.client.HttpClients
3129import software.amazon.awssdk.auth.credentials.AwsCredentialsProvider
3230import software.amazon.awssdk.http.ContentStreamProvider
3331import software.amazon.awssdk.http.HttpExecuteRequest
3432import software.amazon.awssdk.http.SdkHttpMethod
3533import software.amazon.awssdk.http.SdkHttpRequest
3634import software.amazon.awssdk.http.apache.ApacheHttpClient
3735import software.amazon.awssdk.http.auth.aws.signer.AwsV4HttpSigner
36+ import software.aws.toolkits.jetbrains.core.AwsClientManager
3837import java.io.ByteArrayOutputStream
3938import java.net.ConnectException
4039
@@ -54,16 +53,11 @@ private class BasicOtlpSpanProcessor(
5453 val baos = ByteArrayOutputStream ()
5554 item.writeBinaryTo(baos)
5655
57- HttpClients .createDefault().use { client ->
58- val request = HttpPost (traceUrl).apply {
59- entity = ByteArrayEntity (baos.toByteArray()).apply {
60- setContentType(" application/x-protobuf" )
61- }
62- }
63- client.execute(request).use {
64- // Response consumed and closed
56+ HttpRequests .post(traceUrl, " application/x-protobuf" )
57+ .userAgent(AwsClientManager .getUserAgent())
58+ .connect { request ->
59+ request.write(baos.toByteArray())
6560 }
66- }
6761 } catch (e: CancellationException ) {
6862 throw e
6963 } catch (e: ConnectException ) {
0 commit comments