svn commit: r1725303 - /sling/trunk/contrib/extensions/distribution/core/src/main/java/org/apache/sling/distribution/transport/impl/SimpleHttpDistributionTransport.java

[tommaso]

Author: tommaso
Date: Mon Jan 18 16:38:45 2016
New Revision: 1725303

URL: http://svn.apache.org/viewvc?rev=1725303&view=rev
Log:
SLING-5439 - HTTP entity / Content should be discarded

Modified:
    
sling/trunk/contrib/extensions/distribution/core/src/main/java/org/apache/sling/distribution/transport/impl/SimpleHttpDistributionTransport.java

Modified: 
sling/trunk/contrib/extensions/distribution/core/src/main/java/org/apache/sling/distribution/transport/impl/SimpleHttpDistributionTransport.java
URL: 
http://svn.apache.org/viewvc/sling/trunk/contrib/extensions/distribution/core/src/main/java/org/apache/sling/distribution/transport/impl/SimpleHttpDistributionTransport.java?rev=1725303&r1=1725302&r2=1725303&view=diff
==============================================================================
--- 
sling/trunk/contrib/extensions/distribution/core/src/main/java/org/apache/sling/distribution/transport/impl/SimpleHttpDistributionTransport.java
 (original)
+++ 
sling/trunk/contrib/extensions/distribution/core/src/main/java/org/apache/sling/distribution/transport/impl/SimpleHttpDistributionTransport.java
 Mon Jan 18 16:38:45 2016
@@ -94,17 +94,18 @@ public class SimpleHttpDistributionTrans
                 Request req = 
Request.Post(distributionEndpoint.getUri()).useExpectContinue();
 
                 InputStream inputStream = null;
-                Response response = null;
                 try {
                     inputStream = distributionPackage.createInputStream();
 
                     req = req.bodyStream(inputStream, 
ContentType.APPLICATION_OCTET_STREAM);
-                    response = executor.execute(req);
+
+                    Response response = executor.execute(req);
+
+                    response.discardContent();
                 } finally {
                     IOUtils.closeQuietly(inputStream);
                 }
 
-                Content content = response.returnContent();
                 log.debug("delivered packageId={}, endpoint={}", 
distributionPackage.getId(), distributionEndpoint.getUri());
             } catch (HttpHostConnectException e) {
                 throw new RecoverableDistributionException("endpoint not 
available " + distributionEndpoint.getUri(), e);
@@ -192,7 +193,6 @@ public class SimpleHttpDistributionTrans
         distributionContext.put(contextKeyExecutor, executor);
 
         return executor;
-
     }
 
 }