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 60f457ee39 Fixed knative
60f457ee39 is described below
commit 60f457ee39c201e03cd7c0ddd7beaea3d1376963
Author: Jiri Ondrusek <[email protected]>
AuthorDate: Fri Mar 28 13:45:21 2025 +0100
Fixed knative
---
.../quarkus/component/knative/deployment/KnativeProcessor.java | 7 ++++---
.../camel/quarkus/component/knative/KnativeConsumerRecorder.java | 6 ++++--
.../camel/quarkus/component/knative/KnativeProducerRecorder.java | 6 +++---
.../apache/camel/quarkus/component/knative/KnativeRecorder.java | 5 +++--
4 files changed, 14 insertions(+), 10 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 14678d206b..6a2020eb01 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
@@ -73,23 +73,24 @@ class KnativeProcessor {
@Record(ExecutionTime.RUNTIME_INIT)
@BuildStep
- CamelRuntimeBeanBuildItem knativeComponent(KnativeRecorder recorder) {
+ CamelRuntimeBeanBuildItem knativeComponent(CamelContextBuildItem context,
KnativeRecorder recorder) {
return new CamelRuntimeBeanBuildItem(
KnativeConstants.SCHEME,
KnativeComponent.class.getName(),
- recorder.createKnativeComponent());
+ recorder.createKnativeComponent(context.getCamelContext()));
}
@Record(ExecutionTime.RUNTIME_INIT)
@BuildStep
CamelRuntimeBeanBuildItem knativeConsumerCustomizer(
KnativeConsumerRecorder recorder,
+ CamelContextBuildItem context,
VertxWebRouterBuildItem router) {
return new CamelRuntimeBeanBuildItem(
FEATURE + "-consumer-customizer",
ComponentCustomizer.class.getName(),
-
recorder.createKnativeConsumerFactoryCustomizer(router.getHttpRouter()));
+
recorder.createKnativeConsumerFactoryCustomizer(context.getCamelContext(),
router.getHttpRouter()));
}
@Record(ExecutionTime.RUNTIME_INIT)
diff --git
a/extensions/knative/runtime/src/main/java/org/apache/camel/quarkus/component/knative/KnativeConsumerRecorder.java
b/extensions/knative/runtime/src/main/java/org/apache/camel/quarkus/component/knative/KnativeConsumerRecorder.java
index 4ec990df53..a0a97e86c8 100644
---
a/extensions/knative/runtime/src/main/java/org/apache/camel/quarkus/component/knative/KnativeConsumerRecorder.java
+++
b/extensions/knative/runtime/src/main/java/org/apache/camel/quarkus/component/knative/KnativeConsumerRecorder.java
@@ -19,6 +19,7 @@ package org.apache.camel.quarkus.component.knative;
import io.quarkus.runtime.RuntimeValue;
import io.quarkus.runtime.annotations.Recorder;
import io.vertx.ext.web.Router;
+import org.apache.camel.CamelContext;
import org.apache.camel.Component;
import org.apache.camel.component.knative.KnativeComponent;
import org.apache.camel.component.knative.http.KnativeHttpConsumerFactory;
@@ -26,8 +27,9 @@ import org.apache.camel.spi.ComponentCustomizer;
@Recorder
public class KnativeConsumerRecorder {
- public RuntimeValue<ComponentCustomizer>
createKnativeConsumerFactoryCustomizer(RuntimeValue<Router> router) {
- KnativeHttpConsumerFactory factory = new KnativeHttpConsumerFactory();
+ public RuntimeValue<ComponentCustomizer>
createKnativeConsumerFactoryCustomizer(RuntimeValue<CamelContext> camelContext,
+ RuntimeValue<Router> router) {
+ KnativeHttpConsumerFactory factory = new
KnativeHttpConsumerFactory(camelContext.getValue());
factory.setRouter(router.getValue());
ComponentCustomizer cf = new ComponentCustomizer() {
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 b4db90b3d6..38a852218c 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
@@ -29,11 +29,11 @@ import org.apache.camel.spi.ComponentCustomizer;
@Recorder
public class KnativeProducerRecorder {
- public RuntimeValue<ComponentCustomizer>
createKnativeProducerFactoryCustomizer(RuntimeValue<CamelContext> context,
+ public RuntimeValue<ComponentCustomizer>
createKnativeProducerFactoryCustomizer(RuntimeValue<CamelContext> camelContext,
Supplier<Vertx> vertx) {
- KnativeHttpProducerFactory factory = new KnativeHttpProducerFactory();
+ KnativeHttpProducerFactory factory = new
KnativeHttpProducerFactory(camelContext.getValue());
factory.setVertx(vertx.get());
- factory.setCamelContext(context.getValue());
+ factory.setCamelContext(camelContext.getValue());
ComponentCustomizer cf = new ComponentCustomizer() {
@Override
diff --git
a/extensions/knative/runtime/src/main/java/org/apache/camel/quarkus/component/knative/KnativeRecorder.java
b/extensions/knative/runtime/src/main/java/org/apache/camel/quarkus/component/knative/KnativeRecorder.java
index 67ce910a37..f6c7d2dba7 100644
---
a/extensions/knative/runtime/src/main/java/org/apache/camel/quarkus/component/knative/KnativeRecorder.java
+++
b/extensions/knative/runtime/src/main/java/org/apache/camel/quarkus/component/knative/KnativeRecorder.java
@@ -18,11 +18,12 @@ package org.apache.camel.quarkus.component.knative;
import io.quarkus.runtime.RuntimeValue;
import io.quarkus.runtime.annotations.Recorder;
+import org.apache.camel.CamelContext;
import org.apache.camel.component.knative.KnativeComponent;
@Recorder
public class KnativeRecorder {
- public RuntimeValue<KnativeComponent> createKnativeComponent() {
- return new RuntimeValue<>(new KnativeComponent());
+ public RuntimeValue<KnativeComponent>
createKnativeComponent(RuntimeValue<CamelContext> camelContext) {
+ return new RuntimeValue<>(new
KnativeComponent(camelContext.getValue()));
}
}
