fixed kamelet #5849

apache · Mar 8, 2024 · 2816632 · 2816632
1 parent 3b0cebc
commit 2816632
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/...src/main/java/org/apache/camel/quarkus/component/kamelet/deployment/KameletProcessor.java b/...src/main/java/org/apache/camel/quarkus/component/kamelet/deployment/KameletProcessor.java
@@ -130,6 +130,11 @@ CamelContextCustomizerBuildItem configureTemplates(
             resource.setLocation(originalResource.getLocation());
             resource.setExists(originalResource.exists());
             definition.setResource(resource);
+            //remove references to camelContext https://github.com/apache/camel-quarkus/issues/5849
+            definition.setCamelContext(null);
+            if (definition.getRoute() != null && definition.getRoute().getOutputs() != null) {
+                definition.getRoute().getOutputs().forEach(o -> o.setCamelContext(null));
+            }
         });
 
         return new CamelContextCustomizerBuildItem(

diff --git a/...let/runtime/src/main/java/org/apache/camel/quarkus/component/kamelet/KameletRecorder.java b/...let/runtime/src/main/java/org/apache/camel/quarkus/component/kamelet/KameletRecorder.java
@@ -58,6 +58,11 @@ public void configure(CamelContext context) {
                                 }
                             }
                         }
+                        //return references to camelContext https://github.com/apache/camel-quarkus/issues/5849
+                        definition.setCamelContext(context);
+                        if (definition.getRoute() != null && definition.getRoute().getOutputs() != null) {
+                            definition.getRoute().getOutputs().forEach(o -> o.setCamelContext(context));
+                        }
                     }
                     context.getCamelContextExtension().getContextPlugin(Model.class).addRouteTemplateDefinitions(definitions);
                 } catch (Exception e) {