squakez commented on code in PR #20529:
URL: https://github.com/apache/camel/pull/20529#discussion_r2639036450
##########
components/camel-telemetry/src/main/java/org/apache/camel/telemetry/TraceProcessorsInterceptStrategy.java:
##########
@@ -42,13 +48,15 @@ public Processor wrapProcessorInInterceptors(
return new DelegateAsyncProcessor(new TraceProcessor(target,
processorDefinition));
}
- private class TraceProcessor implements Processor {
+ private class TraceProcessor implements AsyncProcessor {
Review Comment:
I haven't found any DefaultAsyncProcessor in the code base. Did you mean by
any chance DelegateAsyncProcessor? in that case, the latter is the one really
used here, as this private processor class is already wrapped and used as a
delegate by the component.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
