(camel-quarkus) 37/39: Fixed knative after change of CAMEL-21358

[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 82f42aaa7ec1268cf74e8d6c97986d850b5b7405
Author: JiriOndrusek <ondrusek.j...@gmail.com>
AuthorDate: Thu Nov 7 14:46:11 2024 +0100

    Fixed knative after change of CAMEL-21358
---
 .../quarkus/component/knative/deployment/KnativeProcessor.java    | 8 +++++++-
 .../camel/quarkus/component/knative/KnativeProducerRecorder.java  | 4 +++-
 2 files changed, 10 insertions(+), 2 deletions(-)

diff --git 
a/extensions/knative/deployment/src/main/java/org/apache/camel/quarkus/component/knative/deployment/KnativeProcessor.java
 
b/extensions/knative/deployment/src/main/java/org/apache/camel/quarkus/component/knative/deployment/KnativeProcessor.java
index 3076c00cab..14678d206b 100644
--- 
a/extensions/knative/deployment/src/main/java/org/apache/camel/quarkus/component/knative/deployment/KnativeProcessor.java
+++ 
b/extensions/knative/deployment/src/main/java/org/apache/camel/quarkus/component/knative/deployment/KnativeProcessor.java
@@ -24,8 +24,10 @@ import io.quarkus.deployment.annotations.ExecutionTime;
 import io.quarkus.deployment.annotations.Record;
 import io.quarkus.deployment.builditem.FeatureBuildItem;
 import io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem;
+import io.quarkus.runtime.RuntimeValue;
 import io.quarkus.vertx.core.deployment.CoreVertxBuildItem;
 import io.quarkus.vertx.http.deployment.VertxWebRouterBuildItem;
+import org.apache.camel.CamelContext;
 import org.apache.camel.component.knative.KnativeComponent;
 import org.apache.camel.component.knative.KnativeConstants;
 import org.apache.camel.component.knative.spi.KnativeEnvironment;
@@ -33,6 +35,7 @@ import org.apache.camel.component.knative.spi.KnativeResource;
 import org.apache.camel.quarkus.component.knative.KnativeConsumerRecorder;
 import org.apache.camel.quarkus.component.knative.KnativeProducerRecorder;
 import org.apache.camel.quarkus.component.knative.KnativeRecorder;
+import org.apache.camel.quarkus.core.deployment.spi.CamelContextBuildItem;
 import org.apache.camel.quarkus.core.deployment.spi.CamelRuntimeBeanBuildItem;
 import org.apache.camel.quarkus.core.deployment.spi.CamelServiceFilter;
 import 
org.apache.camel.quarkus.core.deployment.spi.CamelServiceFilterBuildItem;
@@ -92,12 +95,15 @@ class KnativeProcessor {
     @Record(ExecutionTime.RUNTIME_INIT)
     @BuildStep
     CamelRuntimeBeanBuildItem knativeProducerCustomizer(
+            CamelContextBuildItem context,
             KnativeProducerRecorder recorder,
             CoreVertxBuildItem vertx) {
 
+        RuntimeValue<CamelContext> camelContext = context.getCamelContext();
+
         return new CamelRuntimeBeanBuildItem(
                 FEATURE + "-producer-customizer",
                 ComponentCustomizer.class.getName(),
-                
recorder.createKnativeProducerFactoryCustomizer(vertx.getVertx()));
+                recorder.createKnativeProducerFactoryCustomizer(camelContext, 
vertx.getVertx()));
     }
 }
diff --git 
a/extensions/knative/runtime/src/main/java/org/apache/camel/quarkus/component/knative/KnativeProducerRecorder.java
 
b/extensions/knative/runtime/src/main/java/org/apache/camel/quarkus/component/knative/KnativeProducerRecorder.java
index ef173795f4..516d619c5e 100644
--- 
a/extensions/knative/runtime/src/main/java/org/apache/camel/quarkus/component/knative/KnativeProducerRecorder.java
+++ 
b/extensions/knative/runtime/src/main/java/org/apache/camel/quarkus/component/knative/KnativeProducerRecorder.java
@@ -21,6 +21,7 @@ import java.util.function.Supplier;
 import io.quarkus.runtime.RuntimeValue;
 import io.quarkus.runtime.annotations.Recorder;
 import io.vertx.core.Vertx;
+import org.apache.camel.CamelContext;
 import org.apache.camel.Component;
 import org.apache.camel.component.knative.KnativeComponent;
 import org.apache.camel.component.knative.http.KnativeHttpProducerFactory;
@@ -28,9 +29,10 @@ import org.apache.camel.spi.ComponentCustomizer;
 
 @Recorder
 public class KnativeProducerRecorder {
-    public RuntimeValue<ComponentCustomizer> 
createKnativeProducerFactoryCustomizer(Supplier<Vertx> vertx) {
+    public RuntimeValue<ComponentCustomizer> 
createKnativeProducerFactoryCustomizer(RuntimeValue<CamelContext> context, 
Supplier<Vertx> vertx) {
         KnativeHttpProducerFactory factory = new KnativeHttpProducerFactory();
         factory.setVertx(vertx.get());
+        factory.setCamelContext(context.getValue());
 
         ComponentCustomizer cf = new ComponentCustomizer() {
             @Override