You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ji...@apache.org on 2024/03/08 13:57:15 UTC
(camel-quarkus) branch camel-main updated: fixed kamelet #5849
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
The following commit(s) were added to refs/heads/camel-main by this push:
new 2816632026 fixed kamelet #5849
2816632026 is described below
commit 28166320260b01c0fba8a73774c7fe8e83a3d762
Author: JiriOndrusek <on...@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) {