@Configuration
public class CamelOtelConfiguration {
  public CamelOtelConfiguration(CamelContext camelContext, OpenTelemetryTracer tracer) {
    var strategy = new OpenTelemetryTracingStrategy(tracer);
    tracer.setTracingStrategy(strategy);
    camelContext.getCamelContextExtension().addInterceptStrategy(strategy);
  }
}

opentelemetry:
  exclude-patterns:
    - direct*

  @Override
  public void configure() throws Exception {

    from("direct:wiretap-test").id("wiretap-test")
      .wireTap("direct:wiretapped")
      .delay(200)
      .process(messageLoggingProcess);

    from("direct:wiretapped")
      .delay(300)
      .process(messageLoggingProcess);