|
3 | 3 |
|
4 | 4 | package com.azure.monitor.opentelemetry.autoconfigure; |
5 | 5 |
|
| 6 | +import com.azure.core.http.HttpClient; |
6 | 7 | import com.azure.core.http.HttpPipeline; |
| 8 | +import com.azure.core.http.HttpPipelineBuilder; |
| 9 | +import com.azure.core.http.policy.HttpPipelinePolicy; |
| 10 | +import com.azure.monitor.opentelemetry.autoconfigure.implementation.NoopTracer; |
7 | 11 | import com.azure.monitor.opentelemetry.autoconfigure.implementation.models.MessageData; |
8 | 12 | import com.azure.monitor.opentelemetry.autoconfigure.implementation.models.MetricsData; |
9 | 13 | import com.azure.monitor.opentelemetry.autoconfigure.implementation.models.RemoteDependencyData; |
|
19 | 23 | import io.opentelemetry.api.trace.Tracer; |
20 | 24 | import io.opentelemetry.context.Scope; |
21 | 25 | import io.opentelemetry.sdk.OpenTelemetrySdk; |
22 | | -import org.junit.jupiter.api.Disabled; |
23 | 26 | import org.junit.jupiter.api.Test; |
| 27 | +import reactor.util.annotation.Nullable; |
24 | 28 |
|
25 | 29 | import java.net.URL; |
| 30 | +import java.util.ArrayList; |
26 | 31 | import java.util.Collections; |
| 32 | +import java.util.List; |
27 | 33 | import java.util.Map; |
28 | 34 | import java.util.concurrent.CountDownLatch; |
29 | 35 |
|
30 | 36 | import static java.util.concurrent.TimeUnit.SECONDS; |
31 | 37 | import static org.assertj.core.api.Assertions.assertThat; |
32 | 38 | import static org.assertj.core.api.Assertions.entry; |
33 | 39 |
|
34 | | -@Disabled |
35 | | -public class AzureMonitorExportersEndToEndTest extends MonitorExporterClientTestBase { |
| 40 | +public class AzureMonitorExportersEndToEndTest { |
36 | 41 |
|
37 | 42 | private static final String CONNECTION_STRING_ENV = "InstrumentationKey=00000000-0000-0000-0000-0FEEDDADBEEF;" |
38 | 43 | + "IngestionEndpoint=https://test.in.applicationinsights.azure.com/;" |
@@ -70,6 +75,21 @@ public void testBuildTraceExporter() throws Exception { |
70 | 75 | validateSpan(spanTelemetryItem); |
71 | 76 | } |
72 | 77 |
|
| 78 | + HttpPipeline getHttpPipeline(@Nullable HttpPipelinePolicy policy, HttpClient httpClient) { |
| 79 | + List<HttpPipelinePolicy> policies = new ArrayList<>(); |
| 80 | + if (policy != null) { |
| 81 | + policies.add(policy); |
| 82 | + } |
| 83 | + return new HttpPipelineBuilder().httpClient(httpClient) |
| 84 | + .policies(policies.toArray(new HttpPipelinePolicy[0])) |
| 85 | + .tracer(new NoopTracer()) |
| 86 | + .build(); |
| 87 | + } |
| 88 | + |
| 89 | + HttpPipeline getHttpPipeline(@Nullable HttpPipelinePolicy policy) { |
| 90 | + return getHttpPipeline(policy, HttpClient.createDefault()); |
| 91 | + } |
| 92 | + |
73 | 93 | @Test |
74 | 94 | public void testBuildMetricExporter() throws Exception { |
75 | 95 | // create the OpenTelemetry SDK |
|
0 commit comments