This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch kamelet2 in repository https://gitbox.apache.org/repos/asf/camel.git
commit 5f9005a75a9827a8323b9c92f6224ced1f68865b Author: Claus Ibsen <[email protected]> AuthorDate: Sun Jan 26 14:09:50 2025 +0100 CAMEL-21599: camel-kamelet - Rework error handler for kamelets to be more standard Camel. WIP --- .../src/main/java/org/apache/camel/component/kamelet/Kamelet.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/components/camel-kamelet/src/main/java/org/apache/camel/component/kamelet/Kamelet.java b/components/camel-kamelet/src/main/java/org/apache/camel/component/kamelet/Kamelet.java index 46bd341004e..a67401ce646 100644 --- a/components/camel-kamelet/src/main/java/org/apache/camel/component/kamelet/Kamelet.java +++ b/components/camel-kamelet/src/main/java/org/apache/camel/component/kamelet/Kamelet.java @@ -208,7 +208,8 @@ public final class Kamelet { // has any error handler or not (if not then we should also not use error handler in the kamelet) ModelCamelContext mcc = (ModelCamelContext) in.getCamelContext(); ProcessorDefinition<?> proc = mcc.getProcessorDefinition(ppid); - // TODO: should this be wrapped or not + // TODO: Make API in ProcessorDefinitionHelper we can reuse that + // checks for this like in ProcessorReifer.wrapChannel boolean tryBlock = proc != null && ProcessorDefinitionHelper.isParentOfType(TryDefinition.class, proc, true); if (tryBlock) { def.setErrorHandlerFactory(new NoErrorHandlerBuilder());
