Author: davsclaus
Date: Sat May 12 10:11:37 2012
New Revision: 1337495
URL: http://svn.apache.org/viewvc?rev=1337495&view=rev
Log:
CAMEL-5274: Fixed jetty http client issue with streams may be corrupt. Code
aligned like http/http4 producers.
Modified:
camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/DefaultJettyHttpBinding.java
camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyContentExchange.java
Modified:
camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/DefaultJettyHttpBinding.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/DefaultJettyHttpBinding.java?rev=1337495&r1=1337494&r2=1337495&view=diff
==============================================================================
---
camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/DefaultJettyHttpBinding.java
(original)
+++
camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/DefaultJettyHttpBinding.java
Sat May 12 10:11:37 2012
@@ -166,7 +166,7 @@ public class DefaultJettyHttpBinding imp
throw new RuntimeCamelException("Cannot deserialize body to
Java object", e);
}
} else {
- // just grab the content as string
+ // just grab the raw content body
return httpExchange.getBody();
}
}
Modified:
camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyContentExchange.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyContentExchange.java?rev=1337495&r1=1337494&r2=1337495&view=diff
==============================================================================
---
camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyContentExchange.java
(original)
+++
camel/trunk/components/camel-jetty/src/main/java/org/apache/camel/component/jetty/JettyContentExchange.java
Sat May 12 10:11:37 2012
@@ -151,8 +151,9 @@ public class JettyContentExchange extend
return headers;
}
- public String getBody() throws UnsupportedEncodingException {
- return super.getResponseContent();
+ public byte[] getBody() {
+ // must return the content as raw bytes
+ return super.getResponseContentBytes();
}
public String getUrl() {
