(camel) branch main updated: chore(components): docling stream closure

[pc...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

pcongiusti pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new 2ba0dd8ddfbe chore(components): docling stream closure
2ba0dd8ddfbe is described below

commit 2ba0dd8ddfbea0f2fe088936dab2d95ccb682cca
Author: Pasquale Congiusti <pa...@gmail.com>
AuthorDate: Wed Nov 19 12:52:06 2025 +0100

    chore(components): docling stream closure
---
 .../apache/camel/component/docling/DoclingProducer.java  | 16 ++++++----------
 1 file changed, 6 insertions(+), 10 deletions(-)

diff --git a/components/camel-ai/camel-docling/src/main/java/org/apache/camel/component/docling/DoclingProducer.java b/components/camel-ai/camel-docling/src/main/java/org/apache/camel/component/docling/DoclingProducer.java
index d5bbe64cab54..3306dec0e39d 100644
--- a/components/camel-ai/camel-docling/src/main/java/org/apache/camel/component/docling/DoclingProducer.java
+++ b/components/camel-ai/camel-docling/src/main/java/org/apache/camel/component/docling/DoclingProducer.java
@@ -29,6 +29,7 @@ import java.util.List;
 import java.util.Map;
 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
+import java.util.stream.Stream;
 
 import org.apache.camel.Exchange;
 import org.apache.camel.InvalidPayloadException;
@@ -650,10 +651,6 @@ public class DoclingProducer extends DefaultProducer {
                                            + ". Expected List<String>, List<File>, String[], File[], or directory path");
     }
 
-    private String convertUsingDoclingServe(String inputPath, String outputFormat) throws Exception {
-        return convertUsingDoclingServe(inputPath, outputFormat, null);
-    }
-
     private String convertUsingDoclingServe(String inputPath, String outputFormat, Exchange exchange) throws Exception {
         // Check for header override
         boolean useAsync = configuration.isUseAsyncMode();
@@ -902,10 +899,9 @@ public class DoclingProducer extends DefaultProducer {
     }
 
     private void deleteDirectory(Path directory) {
-        try {
-            if (Files.exists(directory)) {
-                Files.walk(directory)
-                        .sorted((a, b) -> b.compareTo(a)) // Delete files before directories
+        if (Files.exists(directory)) {
+            try (Stream<Path> paths = Files.walk(directory)) {
+                paths.sorted((a, b) -> b.compareTo(a)) // Delete files before directories
                         .forEach(path -> {
                             try {
                                 Files.delete(path);
@@ -913,9 +909,9 @@ public class DoclingProducer extends DefaultProducer {
                                 LOG.warn("Failed to delete temporary file: {}", path, e);
                             }
                         });
+            } catch (IOException e) {
+                LOG.warn("Failed to clean up temporary directory: {}", directory, e);
             }
-        } catch (IOException e) {
-            LOG.warn("Failed to clean up temporary directory: {}", directory, e);
         }
     }