Author: ningjiang
Date: Tue Dec 18 07:11:19 2012
New Revision: 1423301
URL: http://svn.apache.org/viewvc?rev=1423301&view=rev
Log:
CAMEL-5890 Fix the same NPE issue in HttpEntityConverter
Modified:
camel/trunk/components/camel-http4/src/main/java/org/apache/camel/component/http4/HttpEntityConverter.java
Modified:
camel/trunk/components/camel-http4/src/main/java/org/apache/camel/component/http4/HttpEntityConverter.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-http4/src/main/java/org/apache/camel/component/http4/HttpEntityConverter.java?rev=1423301&r1=1423300&r2=1423301&view=diff
==============================================================================
---
camel/trunk/components/camel-http4/src/main/java/org/apache/camel/component/http4/HttpEntityConverter.java
(original)
+++
camel/trunk/components/camel-http4/src/main/java/org/apache/camel/component/http4/HttpEntityConverter.java
Tue Dec 18 07:11:19 2012
@@ -48,7 +48,7 @@ public final class HttpEntityConverter {
@Converter
public static HttpEntity toHttpEntity(String str, Exchange exchange)
throws Exception {
- if (GZIPHelper.isGzip(exchange.getIn())) {
+ if (exchange != null && GZIPHelper.isGzip(exchange.getIn())) {
byte[] data =
exchange.getContext().getTypeConverter().convertTo(byte[].class, str);
return asHttpEntity(data, exchange);
} else {
@@ -58,33 +58,36 @@ public final class HttpEntityConverter {
}
private static HttpEntity asHttpEntity(InputStream in, Exchange exchange)
throws IOException {
- String contentEncoding =
exchange.getIn().getHeader(Exchange.CONTENT_ENCODING, String.class);
- String contentType = ExchangeHelper.getContentType(exchange);
-
InputStreamEntity entity;
if (!exchange.getProperty(Exchange.SKIP_GZIP_ENCODING, Boolean.FALSE,
Boolean.class)) {
+ String contentEncoding =
exchange.getIn().getHeader(Exchange.CONTENT_ENCODING, String.class);
entity = new
InputStreamEntity(GZIPHelper.compressGzip(contentEncoding, in), -1);
} else {
entity = new InputStreamEntity(in, -1);
}
- entity.setContentEncoding(contentEncoding);
- entity.setContentType(contentType);
+ if (exchange != null) {
+ String contentEncoding =
exchange.getIn().getHeader(Exchange.CONTENT_ENCODING, String.class);
+ String contentType = ExchangeHelper.getContentType(exchange);
+ entity.setContentEncoding(contentEncoding);
+ entity.setContentType(contentType);
+ }
return entity;
}
private static HttpEntity asHttpEntity(byte[] data, Exchange exchange)
throws Exception {
- String contentEncoding =
exchange.getIn().getHeader(Exchange.CONTENT_ENCODING, String.class);
- String contentType = ExchangeHelper.getContentType(exchange);
-
InputStreamEntity entity;
- if (!exchange.getProperty(Exchange.SKIP_GZIP_ENCODING, Boolean.FALSE,
Boolean.class)) {
+ if (exchange != null &&
!exchange.getProperty(Exchange.SKIP_GZIP_ENCODING, Boolean.FALSE,
Boolean.class)) {
+ String contentEncoding =
exchange.getIn().getHeader(Exchange.CONTENT_ENCODING, String.class);
entity = new
InputStreamEntity(GZIPHelper.compressGzip(contentEncoding, data), -1);
} else {
entity = new InputStreamEntity(new ByteArrayInputStream(data), -1);
}
- entity.setContentEncoding(contentEncoding);
- entity.setContentType(contentType);
-
+ if (exchange != null) {
+ String contentEncoding =
exchange.getIn().getHeader(Exchange.CONTENT_ENCODING, String.class);
+ String contentType = ExchangeHelper.getContentType(exchange);
+ entity.setContentEncoding(contentEncoding);
+ entity.setContentType(contentType);
+ }
return entity;
}
}
\ No newline at end of file
