Spring/spring-ws
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Buffering input seems unnecessary, content-length is always > 0.

Browse Source
This commit is contained in:
Arjen Poutsma
2007-04-10 12:08:15 +00:00
parent cd9e6a1829
commit 64124b0886
1 changed files with 2 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
core/src/main/java/org/springframework/ws/transport/http/AbstractHttpWebServiceConnection.java
View File

@@ -16,14 +16,12 @@
package org.springframework.ws.transport.http;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.Iterator;
import java.util.zip.GZIPInputStream;
import org.springframework.util.FileCopyUtils;
import org.springframework.ws.transport.AbstractWebServiceConnection;
import org.springframework.ws.transport.FaultAwareWebServiceConnection;
import org.springframework.ws.transport.TransportInputStream;
@@ -44,21 +42,12 @@ public abstract class AbstractHttpWebServiceConnection extends AbstractWebServic
protected static final int HTTP_STATUS_INTERNAL_ERROR = 500;
private byte[] bufferedInput;
protected final TransportOutputStream createTransportOutputStream() throws IOException {
return new HttpClientTransportOutputStream();
}
protected final boolean hasResponse() throws IOException {
long contentLength = getResponseContentLength();
if (contentLength == -1) {
if (bufferedInput == null) {
bufferedInput = FileCopyUtils.copyToByteArray(getResponseInputStream());
}
contentLength = bufferedInput.length;
}
return contentLength > 0;
return getResponseContentLength() > 0;
}
protected final TransportInputStream createTransportInputStream() throws IOException {
@@ -70,14 +59,7 @@ public abstract class AbstractHttpWebServiceConnection extends AbstractWebServic
}
private InputStream getUncompressedResponseInputStream() throws IOException {
InputStream rawInputStream;
if (bufferedInput != null) {
rawInputStream = new ByteArrayInputStream(bufferedInput);
}
else {
rawInputStream = getResponseInputStream();
}
return isGzipResponse() ? new GZIPInputStream(rawInputStream) : rawInputStream;
return isGzipResponse() ? new GZIPInputStream(getResponseInputStream()) : getResponseInputStream();
}
/** Determine whether the given response is a GZIP response. */