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 4d20d3999e98373e40ba9d60c6e221f2ee8c3bfd Author: Claus Ibsen <[email protected]> AuthorDate: Mon Jan 27 11:18:57 2025 +0100 CAMEL-21599: camel-kamelet - Rework error handler for kamelets to be more standard Camel. WIP --- .../java/org/apache/camel/component/kamelet/KameletProcessor.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/components/camel-kamelet/src/main/java/org/apache/camel/component/kamelet/KameletProcessor.java b/components/camel-kamelet/src/main/java/org/apache/camel/component/kamelet/KameletProcessor.java index d58fc2b1ff5..2417aedbd81 100644 --- a/components/camel-kamelet/src/main/java/org/apache/camel/component/kamelet/KameletProcessor.java +++ b/components/camel-kamelet/src/main/java/org/apache/camel/component/kamelet/KameletProcessor.java @@ -53,8 +53,6 @@ public class KameletProcessor extends AsyncProcessorSupport this.camelContext = camelContext; this.name = name; this.processor = AsyncProcessorConverterHelper.convert(processor); - this.component = camelContext.getComponent("kamelet", KameletComponent.class); - this.producer = (KameletProducer) camelContext.getEndpoint("kamelet://" + name).createAsyncProducer(); } @ManagedAttribute(description = "Kamelet name (templateId/routeId?options)") @@ -119,6 +117,9 @@ public class KameletProcessor extends AsyncProcessorSupport @Override protected void doInit() throws Exception { + this.component = camelContext.getComponent("kamelet", KameletComponent.class); + this.producer = (KameletProducer) camelContext.getEndpoint("kamelet://" + name).createAsyncProducer(); + ServiceHelper.initService(processor, producer); // we use the kamelet component (producer) to call the kamelet
