This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit 47a36c1980a6ffefdb1ab2a9521cd36cc4913fbd Author: Claus Ibsen <[email protected]> AuthorDate: Sun Jan 8 21:07:41 2023 +0100 Close resolver --- .../org/apache/camel/dsl/jbang/core/commands/Bind.java | 18 +++++++++++++++--- 1 file changed, 15 insertions(+), 3 deletions(-) diff --git a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/Bind.java b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/Bind.java index 4f8d25739f5..6741b8019f9 100644 --- a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/Bind.java +++ b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/Bind.java @@ -27,6 +27,7 @@ import java.util.Stack; import org.apache.camel.github.GitHubResourceResolver; import org.apache.camel.impl.engine.DefaultResourceResolvers; import org.apache.camel.spi.Resource; +import org.apache.camel.spi.ResourceResolver; import org.apache.camel.util.FileUtil; import org.apache.camel.util.IOHelper; import org.snakeyaml.engine.v2.api.LoadSettings; @@ -131,15 +132,26 @@ class Bind extends CamelCommand { InputStream is; String loc; + Resource res; // try local disk first before github - Resource res = new DefaultResourceResolvers.FileResolver().resolve("file:" + kamelet + ".kamelet.yaml"); + ResourceResolver resolver = new DefaultResourceResolvers.FileResolver(); + try { + res = resolver.resolve("file:" + kamelet + ".kamelet.yaml"); + } finally { + resolver.close(); + } if (res.exists()) { is = res.getInputStream(); loc = res.getLocation(); } else { - res = new GitHubResourceResolver().resolve( - "github:apache:camel-kamelets:main:kamelets/" + kamelet + ".kamelet.yaml"); + resolver = new GitHubResourceResolver(); + try { + res = resolver.resolve( + "github:apache:camel-kamelets:main:kamelets/" + kamelet + ".kamelet.yaml"); + } finally { + resolver.close(); + } loc = res.getLocation(); URL u = new URL(loc); is = u.openStream();
