|
9 | 9 | import static org.assertj.core.api.Assertions.assertThat; |
10 | 10 | import static org.assertj.core.api.Assertions.assertThatCode; |
11 | 11 | import static org.assertj.core.api.Assertions.assertThatThrownBy; |
| 12 | +import static org.mockito.Mockito.mock; |
| 13 | +import static org.mockito.Mockito.when; |
12 | 14 |
|
13 | 15 | import com.linecorp.armeria.testing.junit5.server.SelfSignedCertificateExtension; |
14 | 16 | import io.github.netmikey.logunit.api.LogCapturer; |
15 | 17 | import io.opentelemetry.api.incubator.config.DeclarativeConfigException; |
16 | 18 | import io.opentelemetry.common.ComponentLoader; |
17 | 19 | import io.opentelemetry.internal.testing.CleanupExtension; |
18 | 20 | import io.opentelemetry.sdk.extension.incubator.ExtendedOpenTelemetrySdk; |
| 21 | +import io.opentelemetry.sdk.autoconfigure.internal.SpiHelper; |
19 | 22 | import io.opentelemetry.sdk.extension.incubator.fileconfig.internal.model.OpenTelemetryConfigurationModel; |
20 | 23 | import io.opentelemetry.sdk.extension.incubator.fileconfig.internal.model.SpanProcessorModel; |
21 | 24 | import io.opentelemetry.sdk.extension.incubator.fileconfig.internal.model.TracerProviderModel; |
@@ -173,4 +176,21 @@ void create_ModelCustomizer() { |
173 | 176 | + "telemetry.sdk.name=\"opentelemetry\", " |
174 | 177 | + "telemetry.sdk.version=\""); |
175 | 178 | } |
| 179 | + |
| 180 | + @Test |
| 181 | + void callAutoConfigureListeners_exceptionIsCaught() { |
| 182 | + SpiHelper spiHelper = mock(SpiHelper.class); |
| 183 | + when(spiHelper.getListeners()) |
| 184 | + .thenReturn( |
| 185 | + Collections.singleton( |
| 186 | + sdk -> { |
| 187 | + throw new RuntimeException("Test exception from AutoConfigureListener"); |
| 188 | + })); |
| 189 | + |
| 190 | + assertThatCode( |
| 191 | + () -> |
| 192 | + DeclarativeConfiguration.callAutoConfigureListeners( |
| 193 | + spiHelper, OpenTelemetrySdk.builder().build())) |
| 194 | + .doesNotThrowAnyException(); |
| 195 | + } |
176 | 196 | } |
0 commit comments