(camel) branch main updated: fix(components): beanio dataformat stream closure

[pcongiusti]

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 8b4abcf33ee0 fix(components): beanio dataformat stream closure
8b4abcf33ee0 is described below

commit 8b4abcf33ee08ee54217ee57d6e75216c8aa3772
Author: Pasquale Congiusti <pasquale.congiu...@gmail.com>
AuthorDate: Fri Nov 28 09:45:27 2025 +0100

    fix(components): beanio dataformat stream closure
---
 .../org/apache/camel/dataformat/beanio/BeanIODataFormat.java  | 11 +++--------
 1 file changed, 3 insertions(+), 8 deletions(-)

diff --git 
a/components/camel-beanio/src/main/java/org/apache/camel/dataformat/beanio/BeanIODataFormat.java
 
b/components/camel-beanio/src/main/java/org/apache/camel/dataformat/beanio/BeanIODataFormat.java
index 5ccf57301053..293c7494ed65 100644
--- 
a/components/camel-beanio/src/main/java/org/apache/camel/dataformat/beanio/BeanIODataFormat.java
+++ 
b/components/camel-beanio/src/main/java/org/apache/camel/dataformat/beanio/BeanIODataFormat.java
@@ -196,12 +196,9 @@ public class BeanIODataFormat extends ServiceSupport 
implements DataFormat, Data
         List<Object> results = new ArrayList<>();
         BufferedReader streamReader = IOHelper.buffered(new 
InputStreamReader(stream, getEncoding()));
 
-        BeanReader in = factory.createReader(getStreamName(), streamReader);
-
-        BeanReaderErrorHandler errorHandler = 
getOrCreateBeanReaderErrorHandler(configuration, exchange, results, null);
-        in.setErrorHandler(errorHandler);
-
-        try {
+        try (BeanReader in = factory.createReader(getStreamName(), 
streamReader)) {
+            BeanReaderErrorHandler errorHandler = 
getOrCreateBeanReaderErrorHandler(configuration, exchange, results, null);
+            in.setErrorHandler(errorHandler);
             Object readObject;
             while ((readObject = in.read()) != null) {
                 if (readObject instanceof BeanIOHeader) {
@@ -209,8 +206,6 @@ public class BeanIODataFormat extends ServiceSupport 
implements DataFormat, Data
                 }
                 results.add(readObject);
             }
-        } finally {
-            in.close();
         }
 
         return results;