You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2017/01/12 07:14:25 UTC
[2/2] camel git commit: CAMEL-10577 replace BufferingResponseLisener
with InputStreamResponseListener to avoid hardcoded 2MB limit
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 <ke...@kevinearls.com>
Authored: Wed Jan 11 17:08:11 2017 +0100
Committer: Andrea Cosentino <an...@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());
}
}
};