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 18b757c28b95 chore(dsl): autoclosable stream
18b757c28b95 is described below
commit 18b757c28b9586998f10b3c431d0081cd0e3f231
Author: Pasquale Congiusti <[email protected]>
AuthorDate: Wed Nov 26 09:54:38 2025 +0100
chore(dsl): autoclosable stream
---
.../camel/main/download/BasePackageScanDownloadListener.java | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
diff --git
a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/BasePackageScanDownloadListener.java
b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/BasePackageScanDownloadListener.java
index 6ab6188461ce..cc8cb4667b4a 100644
---
a/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/BasePackageScanDownloadListener.java
+++
b/dsl/camel-kamelet-main/src/main/java/org/apache/camel/main/download/BasePackageScanDownloadListener.java
@@ -38,7 +38,6 @@ import org.apache.camel.spi.Registry;
import org.apache.camel.support.PluginHelper;
import org.apache.camel.util.AnnotationHelper;
import org.apache.camel.util.FileUtil;
-import org.apache.camel.util.IOHelper;
import org.apache.camel.util.StringHelper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -74,9 +73,8 @@ public class BasePackageScanDownloadListener implements
ArtifactDownloadListener
if (packageScanJars) {
String ext = FileUtil.onlyExt(file.getName(), true);
if ("jar".equals(ext)) {
- try {
+ try (JarInputStream is = new JarInputStream(new
FileInputStream(file))) {
Set<String> packages = new HashSet<>();
- JarInputStream is = new JarInputStream(new
FileInputStream(file));
JarEntry entry;
while ((entry = is.getNextJarEntry()) != null) {
final String name = entry.getName().trim();
@@ -88,9 +86,9 @@ public class BasePackageScanDownloadListener implements
ArtifactDownloadListener
String[] arr = packages.toArray(new String[0]);
packageScan(arr);
}
- IOHelper.close(is);
} catch (Exception e) {
// ignore
+ LOG.warn("Some error happened: ignoring", e);
}
}
}
@@ -103,6 +101,7 @@ public class BasePackageScanDownloadListener implements
ArtifactDownloadListener
basePackageScanQuarkus(basePackage);
} catch (Exception e) {
// ignore
+ LOG.warn("Some error happened: ignoring", e);
}
}