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 e5e6cdefae53da5bbcb56606444ba423eb6444a4
Author: JiriOndrusek <on...@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