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 9f644d1560 Fixed saga, docling test modules
9f644d1560 is described below
commit 9f644d1560e567e807f7f6b258ff2e08a991e44f
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")
