Fix inputstreams that weren't closed (frankframework#7323)

lenardvandermaas · Aug 14, 2024 · 6793ecf · 6793ecf
1 parent 67929c4
commit 6793ecf
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/core/src/main/java/org/frankframework/pipes/ReplacingInputStream.java b/core/src/main/java/org/frankframework/pipes/ReplacingInputStream.java
@@ -46,6 +46,13 @@ public class ReplacingInputStream extends InputStream {
 	private final byte[] search;
 	private final InputStream in;
 
+	@Override
+	public void close() throws IOException {
+		if (this.in != null) {
+			this.in.close();
+		}
+	}
+
 	public ReplacingInputStream(InputStream in, String search, String replacement, boolean replaceNonXmlChars,
 								String nonXmlReplacementCharacter, boolean allowUnicodeSupplementaryCharacters) {
 

diff --git a/core/src/main/java/org/frankframework/pipes/ReplacingVariablesInputStream.java b/core/src/main/java/org/frankframework/pipes/ReplacingVariablesInputStream.java
@@ -48,6 +48,13 @@ public class ReplacingVariablesInputStream extends InputStream {
 	private final Queue<Integer> outQueue;
 	private boolean lookingForSuffix = false;
 
+	@Override
+	public void close() throws IOException {
+		if (this.in != null) {
+			this.in.close();
+		}
+	}
+
 	protected ReplacingVariablesInputStream(InputStream in, String variablePrefix, Properties properties) {
 		this.in = in;
 		this.variablePrefix = (variablePrefix + "{").getBytes();