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/6eb5b8f4 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/6eb5b8f4 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/6eb5b8f4 Branch: refs/heads/master Commit: 6eb5b8f4e90fe50981f78051cea2c29b773d5287 Parents: 0c4c7ea Author: Kevin Earls <ke...@kevinearls.com> Authored: Wed Jan 11 17:08:11 2017 +0100 Committer: Andrea Cosentino <anco...@gmail.com> Committed: Thu Jan 12 07:50:57 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/6eb5b8f4/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()); } } };
