(camel-quarkus) 07/27: fixed kamelet #5849

[jiriondrusek]

This is an automated email from the ASF dual-hosted git repository.

jiriondrusek pushed a commit to branch camel-main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git

commit 71d3b812913b9e32d9d344eb9cb5b094a4c116b2
Author: JiriOndrusek <ondrusek.j...@gmail.com>
AuthorDate: Fri Mar 8 14:56:55 2024 +0100

    fixed kamelet #5849
---
 .../camel/quarkus/component/kamelet/deployment/KameletProcessor.java | 5 +++++
 .../org/apache/camel/quarkus/component/kamelet/KameletRecorder.java  | 5 +++++
 2 files changed, 10 insertions(+)

diff --git 
a/extensions/kamelet/deployment/src/main/java/org/apache/camel/quarkus/component/kamelet/deployment/KameletProcessor.java
 
b/extensions/kamelet/deployment/src/main/java/org/apache/camel/quarkus/component/kamelet/deployment/KameletProcessor.java
index 1b9ea1f1c1..1bd217b289 100644
--- 
a/extensions/kamelet/deployment/src/main/java/org/apache/camel/quarkus/component/kamelet/deployment/KameletProcessor.java
+++ 
b/extensions/kamelet/deployment/src/main/java/org/apache/camel/quarkus/component/kamelet/deployment/KameletProcessor.java
@@ -130,6 +130,11 @@ class KameletProcessor {
             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/extensions/kamelet/runtime/src/main/java/org/apache/camel/quarkus/component/kamelet/KameletRecorder.java
 
b/extensions/kamelet/runtime/src/main/java/org/apache/camel/quarkus/component/kamelet/KameletRecorder.java
index 98499932ed..b431298fc0 100644
--- 
a/extensions/kamelet/runtime/src/main/java/org/apache/camel/quarkus/component/kamelet/KameletRecorder.java
+++ 
b/extensions/kamelet/runtime/src/main/java/org/apache/camel/quarkus/component/kamelet/KameletRecorder.java
@@ -58,6 +58,11 @@ public class KameletRecorder {
                                 }
                             }
                         }
+                        //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) {