diff --git a/components/camel-opentelemetry/src/test/java/org/apache/camel/opentelemetry/CamelOpenTelemetryTestSupport.java b/components/camel-opentelemetry/src/test/java/org/apache/camel/opentelemetry/CamelOpenTelemetryTestSupport.java index 26977d6d8f8ce..4c9c6a1e8fd8c 100644 --- a/components/camel-opentelemetry/src/test/java/org/apache/camel/opentelemetry/CamelOpenTelemetryTestSupport.java +++ b/components/camel-opentelemetry/src/test/java/org/apache/camel/opentelemetry/CamelOpenTelemetryTestSupport.java @@ -33,9 +33,11 @@ import io.opentelemetry.context.Context; import io.opentelemetry.sdk.logs.data.LogRecordData; import io.opentelemetry.sdk.trace.data.SpanData; +import org.apache.camel.BindToRegistry; import org.apache.camel.CamelContext; import org.apache.camel.CamelContextAware; import org.apache.camel.spi.InterceptStrategy; +import org.apache.camel.spi.ThreadPoolFactory; import org.apache.camel.test.junit5.CamelTestSupport; import org.awaitility.Awaitility; import org.junit.jupiter.api.AfterEach; @@ -63,6 +65,9 @@ class CamelOpenTelemetryTestSupport extends CamelTestSupport { @RegisterExtension public final CamelOpenTelemetryExtension otelExtension = CamelOpenTelemetryExtension.create(); + @BindToRegistry + ThreadPoolFactory threadPoolFactory = new OpenTelemetryInstrumentedThreadPoolFactory(); + SpanTestData[] expected; Tracer tracer; OpenTelemetryTracer otTracer;