This is an automated email from the ASF dual-hosted git repository. jamesnetherton pushed a commit to branch camel-main in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 05b23208f645b5b379167923f241d6bf24698b19 Author: Jiri Ondrusek <[email protected]> AuthorDate: Fri Jun 5 09:28:04 2026 +0200 Fixed core, nats, velocity - core: Add RuntimeCamelContextCustomizerBuildItem for source location and tracer settings so they survive DefaultConfigurationConfigurer.configure() - nats: Add explicit exchangePattern=InOut for request-reply consumer (CAMEL-23676) - velocity: Update native reflection registration from TreeMap to CaseInsensitiveMap and CopyOnWriteHeadersMap (CAMEL-23691, CAMEL-23681) Co-Authored-By: Claude Opus 4.6 <[email protected]> --- .../camel/quarkus/core/deployment/CamelContextProcessor.java | 12 ++++++------ .../component/velocity/deployment/VelocityProcessor.java | 5 +++-- .../apache/camel/quarkus/component/nats/it/NatsRoutes.java | 2 +- 3 files changed, 10 insertions(+), 9 deletions(-) diff --git a/extensions-core/core/deployment/src/main/java/org/apache/camel/quarkus/core/deployment/CamelContextProcessor.java b/extensions-core/core/deployment/src/main/java/org/apache/camel/quarkus/core/deployment/CamelContextProcessor.java index 9db50cf778..3738e40302 100644 --- a/extensions-core/core/deployment/src/main/java/org/apache/camel/quarkus/core/deployment/CamelContextProcessor.java +++ b/extensions-core/core/deployment/src/main/java/org/apache/camel/quarkus/core/deployment/CamelContextProcessor.java @@ -115,12 +115,12 @@ public class CamelContextProcessor { * @param recorder the recorder * @param producer producer of context customizer build item */ - @Record(ExecutionTime.STATIC_INIT) + @Record(ExecutionTime.RUNTIME_INIT) @BuildStep(onlyIf = SourceLocationEnabled.class) public void enableSourceLocation( CamelContextRecorder recorder, - BuildProducer<CamelContextCustomizerBuildItem> producer) { - producer.produce(new CamelContextCustomizerBuildItem(recorder.createSourceLocationEnabledCustomizer())); + BuildProducer<RuntimeCamelContextCustomizerBuildItem> runtimeProducer) { + runtimeProducer.produce(new RuntimeCamelContextCustomizerBuildItem(recorder.createSourceLocationEnabledCustomizer())); } /** @@ -171,13 +171,13 @@ public class CamelContextProcessor { * @param recorder the recorder * @param producer producer of context customizer build item */ - @Record(ExecutionTime.STATIC_INIT) + @Record(ExecutionTime.RUNTIME_INIT) @BuildStep(onlyIf = TraceEnabled.class) public void enableCamelTrace( CamelConfig config, CamelContextRecorder recorder, - BuildProducer<CamelContextCustomizerBuildItem> producer) { - producer.produce(new CamelContextCustomizerBuildItem(recorder.createBacklogTracerCustomizer(config))); + BuildProducer<RuntimeCamelContextCustomizerBuildItem> runtimeProducer) { + runtimeProducer.produce(new RuntimeCamelContextCustomizerBuildItem(recorder.createBacklogTracerCustomizer(config))); } @Record(ExecutionTime.STATIC_INIT) diff --git a/extensions/velocity/deployment/src/main/java/org/apache/camel/quarkus/component/velocity/deployment/VelocityProcessor.java b/extensions/velocity/deployment/src/main/java/org/apache/camel/quarkus/component/velocity/deployment/VelocityProcessor.java index 308b834f19..bb5499d10b 100644 --- a/extensions/velocity/deployment/src/main/java/org/apache/camel/quarkus/component/velocity/deployment/VelocityProcessor.java +++ b/extensions/velocity/deployment/src/main/java/org/apache/camel/quarkus/component/velocity/deployment/VelocityProcessor.java @@ -17,7 +17,6 @@ package org.apache.camel.quarkus.component.velocity.deployment; import java.util.ArrayList; -import java.util.TreeMap; import io.quarkus.deployment.annotations.BuildProducer; import io.quarkus.deployment.annotations.BuildStep; @@ -27,6 +26,7 @@ import io.quarkus.deployment.builditem.IndexDependencyBuildItem; import io.quarkus.deployment.builditem.nativeimage.NativeImageResourceBuildItem; import io.quarkus.deployment.builditem.nativeimage.ReflectiveClassBuildItem; import org.apache.camel.component.velocity.CamelVelocityClasspathResourceLoader; +import org.apache.camel.util.CaseInsensitiveMap; import org.apache.velocity.runtime.directive.ForeachScope; import org.jboss.jandex.IndexView; @@ -64,7 +64,8 @@ class VelocityProcessor { reflectiveClass.produce( ReflectiveClassBuildItem.builder( - TreeMap.class.getName(), + CaseInsensitiveMap.class.getName(), + "org.apache.camel.support.CopyOnWriteHeadersMap", ForeachScope.class.getName()) .methods() .build()); diff --git a/integration-tests/nats/src/main/java/org/apache/camel/quarkus/component/nats/it/NatsRoutes.java b/integration-tests/nats/src/main/java/org/apache/camel/quarkus/component/nats/it/NatsRoutes.java index e820c37620..a4fec84faa 100644 --- a/integration-tests/nats/src/main/java/org/apache/camel/quarkus/component/nats/it/NatsRoutes.java +++ b/integration-tests/nats/src/main/java/org/apache/camel/quarkus/component/nats/it/NatsRoutes.java @@ -61,7 +61,7 @@ public class NatsRoutes extends RouteBuilder { fromF(maxMsgUriPattern, 3).routeId("3-qmsg-max").bean(natsResource, "storeMessage"); fromF(maxMsgUriPattern, 8).routeId("8-qmsg-max").bean(natsResource, "storeMessage"); - from("natsNoAuth:request-reply").setBody().simple("${body} => Reply"); + from("natsNoAuth:request-reply?exchangePattern=InOut").setBody().simple("${body} => Reply"); from("natsNoAuth:reply").routeId("reply").bean(natsResource, "storeMessage"); }
