camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acosent...@apache.org
Subject [2/2] camel git commit: CAMEL-10577 replace BufferingResponseLisener with InputStreamResponseListener to avoid hardcoded 2MB limit
Date Thu, 12 Jan 2017 07:14:25 GMT
CAMEL-10577 replace BufferingResponseLisener with InputStreamResponseListener to avoid hardcoded
2MB limit


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/83e8e1fc
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/83e8e1fc
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/83e8e1fc

Branch: refs/heads/camel-2.18.x
Commit: 83e8e1fc7a6164b1e05f0ad946631b3c2d25c8ce
Parents: 02bb487
Author: Kevin Earls <kevin@kevinearls.com>
Authored: Wed Jan 11 17:08:11 2017 +0100
Committer: Andrea Cosentino <ancosen@gmail.com>
Committed: Thu Jan 12 08:02:25 2017 +0100

----------------------------------------------------------------------
 .../apache/camel/component/jetty9/JettyContentExchange9.java  | 7 ++-----
 1 file changed, 2 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/83e8e1fc/components/camel-jetty9/src/main/java/org/apache/camel/component/jetty9/JettyContentExchange9.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty9/src/main/java/org/apache/camel/component/jetty9/JettyContentExchange9.java
b/components/camel-jetty9/src/main/java/org/apache/camel/component/jetty9/JettyContentExchange9.java
index 0730053..50f2e43 100644
--- a/components/camel-jetty9/src/main/java/org/apache/camel/component/jetty9/JettyContentExchange9.java
+++ b/components/camel-jetty9/src/main/java/org/apache/camel/component/jetty9/JettyContentExchange9.java
@@ -86,7 +86,7 @@ public class JettyContentExchange9 implements JettyContentExchange {
         closeRequestContentSource();
     }
 
-    protected void onResponseComplete(Result result, byte[] content, String contentType)
{
+    protected void onResponseComplete(Result result, byte[] content) {
         LOG.trace("onResponseComplete");
         done.countDown();
         this.response = result.getResponse();
@@ -226,9 +226,6 @@ public class JettyContentExchange9 implements JettyContentExchange {
 
             @Override
             public void onContent(Response response, ByteBuffer content, Callback callback)
{
-                if (response.getStatus() != SC_OK) {
-                    LOG.warn("Response received {}: {}", response.getStatus(), response.getReason());
-                }
                 byte[] buffer = new byte[content.limit()];
                 content.get(buffer);
                 baos.write(buffer, 0, buffer.length);
@@ -241,7 +238,7 @@ public class JettyContentExchange9 implements JettyContentExchange {
                 if (result.isFailed()) {
                     doTaskCompleted(result.getFailure());
                 } else {
-                    onResponseComplete(result, baos.toByteArray(), null);
+                    onResponseComplete(result, baos.toByteArray());
                 }
             }
         };


Mime
View raw message