|
12 | 12 | import com.google.common.collect.ImmutableMap; |
13 | 13 | import io.opentelemetry.api.baggage.Baggage; |
14 | 14 | import io.opentelemetry.api.common.AttributeKey; |
| 15 | +import io.opentelemetry.common.ComponentLoader; |
15 | 16 | import io.opentelemetry.context.Context; |
16 | 17 | import io.opentelemetry.context.Scope; |
17 | 18 | import io.opentelemetry.sdk.OpenTelemetrySdk; |
18 | 19 | import io.opentelemetry.sdk.autoconfigure.AutoConfiguredOpenTelemetrySdk; |
19 | 20 | import io.opentelemetry.sdk.autoconfigure.AutoConfiguredOpenTelemetrySdkBuilder; |
20 | | -import io.opentelemetry.sdk.autoconfigure.internal.AutoConfigureUtil; |
21 | | -import io.opentelemetry.sdk.autoconfigure.internal.ComponentLoader; |
22 | 21 | import io.opentelemetry.sdk.autoconfigure.internal.SpiHelper; |
23 | 22 | import io.opentelemetry.sdk.autoconfigure.spi.ConfigProperties; |
24 | 23 | import io.opentelemetry.sdk.autoconfigure.spi.logs.ConfigurableLogRecordExporterProvider; |
@@ -113,45 +112,46 @@ private static OpenTelemetrySdk getOpenTelemetrySdk( |
113 | 112 | "none", |
114 | 113 | "otel.logs.exporter", |
115 | 114 | MEMORY_EXPORTER)) |
116 | | - .addPropertiesSupplier(() -> properties); |
117 | | - AutoConfigureUtil.setComponentLoader( |
118 | | - sdkBuilder, |
119 | | - new ComponentLoader() { |
120 | | - @SuppressWarnings("unchecked") |
121 | | - @Override |
122 | | - public <T> List<T> load(Class<T> spiClass) { |
123 | | - if (spiClass == ConfigurableSpanExporterProvider.class) { |
124 | | - return Collections.singletonList( |
125 | | - (T) |
126 | | - new ConfigurableSpanExporterProvider() { |
127 | | - @Override |
128 | | - public SpanExporter createExporter(ConfigProperties configProperties) { |
129 | | - return spanExporter; |
130 | | - } |
131 | | - |
132 | | - @Override |
133 | | - public String getName() { |
134 | | - return MEMORY_EXPORTER; |
135 | | - } |
136 | | - }); |
137 | | - } else if (spiClass == ConfigurableLogRecordExporterProvider.class) { |
138 | | - return Collections.singletonList( |
139 | | - (T) |
140 | | - new ConfigurableLogRecordExporterProvider() { |
141 | | - @Override |
142 | | - public LogRecordExporter createExporter(ConfigProperties configProperties) { |
143 | | - return logRecordExporter; |
144 | | - } |
145 | | - |
146 | | - @Override |
147 | | - public String getName() { |
148 | | - return MEMORY_EXPORTER; |
149 | | - } |
150 | | - }); |
151 | | - } |
152 | | - return spiHelper.load(spiClass); |
153 | | - } |
154 | | - }); |
| 115 | + .addPropertiesSupplier(() -> properties) |
| 116 | + .setComponentLoader( |
| 117 | + new ComponentLoader() { |
| 118 | + @SuppressWarnings("unchecked") |
| 119 | + @Override |
| 120 | + public <T> List<T> load(Class<T> spiClass) { |
| 121 | + if (spiClass == ConfigurableSpanExporterProvider.class) { |
| 122 | + return Collections.singletonList( |
| 123 | + (T) |
| 124 | + new ConfigurableSpanExporterProvider() { |
| 125 | + @Override |
| 126 | + public SpanExporter createExporter( |
| 127 | + ConfigProperties configProperties) { |
| 128 | + return spanExporter; |
| 129 | + } |
| 130 | + |
| 131 | + @Override |
| 132 | + public String getName() { |
| 133 | + return MEMORY_EXPORTER; |
| 134 | + } |
| 135 | + }); |
| 136 | + } else if (spiClass == ConfigurableLogRecordExporterProvider.class) { |
| 137 | + return Collections.singletonList( |
| 138 | + (T) |
| 139 | + new ConfigurableLogRecordExporterProvider() { |
| 140 | + @Override |
| 141 | + public LogRecordExporter createExporter( |
| 142 | + ConfigProperties configProperties) { |
| 143 | + return logRecordExporter; |
| 144 | + } |
| 145 | + |
| 146 | + @Override |
| 147 | + public String getName() { |
| 148 | + return MEMORY_EXPORTER; |
| 149 | + } |
| 150 | + }); |
| 151 | + } |
| 152 | + return spiHelper.load(spiClass); |
| 153 | + } |
| 154 | + }); |
155 | 155 | return sdkBuilder.build().getOpenTelemetrySdk(); |
156 | 156 | } |
157 | 157 |
|
|
0 commit comments