Fixed an error where a retry would cause an IOException: Channel Closed

Author: rpmoore

src/main/java/com/spectralogic/ds3client/Ds3InputStreamEntity.java

@@ -0,0 +1,22 @@
+package com.spectralogic.ds3client;
+
+
+import org.apache.commons.io.IOUtils;
+import org.apache.http.entity.ContentType;
+import org.apache.http.entity.InputStreamEntity;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+
+public class Ds3InputStreamEntity extends InputStreamEntity{
+
+    public Ds3InputStreamEntity(final InputStream inStream, final long length, final ContentType contentType) {
+        super(inStream, length, contentType);
+    }
+
+    @Override
+    public void writeTo(final OutputStream outStream) throws IOException {
+        IOUtils.copy(this.getContent(), outStream);
+    }
+}

src/main/java/com/spectralogic/ds3client/NetworkClientImpl.java

@@ -125,7 +125,7 @@ private HttpRequest buildHttpRequest() throws IOException {
             final String path = this.buildPath();
             if (this.content != null) {
                 final BasicHttpEntityEnclosingRequest httpRequest = new BasicHttpEntityEnclosingRequest(verb, path);
-                httpRequest.setEntity(new InputStreamEntity(this.content, this.ds3Request.getSize(), this.ds3Request.getContentType()));
+                httpRequest.setEntity(new Ds3InputStreamEntity(this.content, this.ds3Request.getSize(), this.ds3Request.getContentType()));
                 return httpRequest;
             } else {
                 return new BasicHttpRequest(verb, path);