This is an automated email from the ASF dual-hosted git repository. github-actions[bot] pushed a commit to branch camel-main in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 348688fb086038b959a27de3e7da8a2c928a4010 Author: Jiří Ondrušek <[email protected]> AuthorDate: Wed Sep 2 08:41:38 2026 +0000 Fixed saga, docling test modules - docling: Camel made body input-source interpretation explicit and secure by default (CAMEL-24422); the test routes receive file paths as message bodies, so they now opt in via allowFilePathSource=true, mirroring camel's own tests. - saga: since CAMEL-24449 a CamelSagaService only consults the Long-Running-Action header when it advertises support; the test routes intentionally propagate the saga id over SEDA/JMS via that header, so the InMemorySagaService now overrides isLongRunningActionHeaderSupported(). The kafka module failure (SedaConsumerNotAvailableException after route restart) is a Camel regression introduced by CAMEL-24408 and needs an upstream camel fix; no camel-quarkus change is appropriate. Co-Authored-By: Claude Fable 5 <[email protected]> --- .../quarkus/component/docling/it/DoclingRoutes.java | 20 ++++++++++---------- .../camel/quarkus/component/saga/it/SagaRoute.java | 9 ++++++++- 2 files changed, 18 insertions(+), 11 deletions(-) diff --git a/integration-tests/docling/src/main/java/org/apache/camel/quarkus/component/docling/it/DoclingRoutes.java b/integration-tests/docling/src/main/java/org/apache/camel/quarkus/component/docling/it/DoclingRoutes.java index cee5370f98..b1b0e77fcd 100644 --- a/integration-tests/docling/src/main/java/org/apache/camel/quarkus/component/docling/it/DoclingRoutes.java +++ b/integration-tests/docling/src/main/java/org/apache/camel/quarkus/component/docling/it/DoclingRoutes.java @@ -26,49 +26,49 @@ public class DoclingRoutes extends RouteBuilder { public void configure() throws Exception { // Route to convert document to Markdown from("direct:convertToMarkdown") - .to("docling:convert?operation=CONVERT_TO_MARKDOWN&contentInBody=true") + .to("docling:convert?allowFilePathSource=true&operation=CONVERT_TO_MARKDOWN&contentInBody=true") .log("Converted to Markdown: ${body}"); // Route to convert document to HTML from("direct:convertToHtml") - .to("docling:convert?operation=CONVERT_TO_HTML&contentInBody=true") + .to("docling:convert?allowFilePathSource=true&operation=CONVERT_TO_HTML&contentInBody=true") .log("Converted to HTML: ${body}"); // Route to extract text from document from("direct:extractText") - .to("docling:convert?operation=EXTRACT_TEXT&contentInBody=true") + .to("docling:convert?allowFilePathSource=true&operation=EXTRACT_TEXT&contentInBody=true") .log("Extracted text: ${body}"); // Route to extract metadata from document from("direct:extractMetadata") - .to("docling:convert?operation=EXTRACT_METADATA&contentInBody=true") + .to("docling:convert?allowFilePathSource=true&operation=EXTRACT_METADATA&contentInBody=true") .log("Extracted metadata: ${body}"); // Route to convert document to JSON from("direct:convertToJson") - .to("docling:convert?operation=CONVERT_TO_JSON&contentInBody=true") + .to("docling:convert?allowFilePathSource=true&operation=CONVERT_TO_JSON&contentInBody=true") .log("Converted to JSON: ${body}"); // Async route to convert document to Markdown from("direct:convertToMarkdownAsync") - .to("docling:convert?operation=CONVERT_TO_MARKDOWN&contentInBody=true&useAsyncMode=true") + .to("docling:convert?allowFilePathSource=true&operation=CONVERT_TO_MARKDOWN&contentInBody=true&useAsyncMode=true") .log("Converted to Markdown (async): ${body}"); // Async route to convert document to HTML from("direct:convertToHtmlAsync") - .to("docling:convert?operation=CONVERT_TO_HTML&contentInBody=true&useAsyncMode=true") + .to("docling:convert?allowFilePathSource=true&operation=CONVERT_TO_HTML&contentInBody=true&useAsyncMode=true") .log("Converted to HTML (async): ${body}"); // Async route to convert document to JSON from("direct:convertToJsonAsync") - .to("docling:convert?operation=CONVERT_TO_JSON&contentInBody=true&useAsyncMode=true") + .to("docling:convert?allowFilePathSource=true&operation=CONVERT_TO_JSON&contentInBody=true&useAsyncMode=true") .log("Converted to JSON (async): ${body}"); from("direct:convertToJsonWithCLI") - .to("docling:convert?operation=CONVERT_TO_JSON&contentInBody=true&useDoclingServe=false"); + .to("docling:convert?allowFilePathSource=true&operation=CONVERT_TO_JSON&contentInBody=true&useDoclingServe=false"); from("direct:batch-markdown") - .to("docling:convert?operation=BATCH_CONVERT_TO_MARKDOWN&batchSize=10&batchParallelism=4&contentInBody=true") + .to("docling:convert?allowFilePathSource=true&operation=BATCH_CONVERT_TO_MARKDOWN&batchSize=10&batchParallelism=4&contentInBody=true") .log("Converted in batch to Markdown: ${body}"); } } diff --git a/integration-tests/saga/src/main/java/org/apache/camel/quarkus/component/saga/it/SagaRoute.java b/integration-tests/saga/src/main/java/org/apache/camel/quarkus/component/saga/it/SagaRoute.java index 8fe8498c3a..8fc79a885d 100644 --- a/integration-tests/saga/src/main/java/org/apache/camel/quarkus/component/saga/it/SagaRoute.java +++ b/integration-tests/saga/src/main/java/org/apache/camel/quarkus/component/saga/it/SagaRoute.java @@ -49,7 +49,14 @@ public class SagaRoute extends RouteBuilder { @Override public void configure() throws Exception { - CamelSagaService sagaService = new InMemorySagaService(); + // The saga id only survives the SEDA / JMS hops below via the Long-Running-Action header, which a + // CamelSagaService must explicitly advertise support for since CAMEL-24449 + CamelSagaService sagaService = new InMemorySagaService() { + @Override + public boolean isLongRunningActionHeaderSupported() { + return true; + } + }; getContext().addService(sagaService); from("direct:saga").saga().propagation(SagaPropagation.REQUIRES_NEW).log("Creating a new order")
