Properly close/flush TransportOutputStream.

Resolves #1206,#1207.
spring-projects · Dec 1, 2021 · ebd7f4a · ebd7f4a
1 parent d2eda53
commit ebd7f4a
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 3 deletions.
diff --git a/spring-ws-core/src/main/java/org/springframework/ws/transport/TransportInputStream.java b/spring-ws-core/src/main/java/org/springframework/ws/transport/TransportInputStream.java
@@ -47,7 +47,9 @@ private InputStream getInputStream() throws IOException {
 
 	@Override
 	public void close() throws IOException {
-		getInputStream().close();
+		if (inputStream != null) {
+			getInputStream().close();
+		}
 	}
 
 	@Override

diff --git a/spring-ws-core/src/main/java/org/springframework/ws/transport/TransportOutputStream.java b/spring-ws-core/src/main/java/org/springframework/ws/transport/TransportOutputStream.java
@@ -45,12 +45,16 @@ private OutputStream getOutputStream() throws IOException {
 
 	@Override
 	public void close() throws IOException {
-		getOutputStream().close();
+		if (outputStream != null) {
+			getOutputStream().close();
+		}
 	}
 
 	@Override
 	public void flush() throws IOException {
-		getOutputStream().flush();
+		if (outputStream != null) {
+			getOutputStream().flush();
+		}
 	}
 
 	@Override