Author: ningjiang
Date: Thu Dec 22 02:37:19 2011
New Revision: 1222006
URL: http://svn.apache.org/viewvc?rev=1222006&view=rev
Log:
CAMEL-4813 Added a converter to turn StringBuffer to InputStream
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/converter/IOConverter.java
camel/trunk/camel-core/src/test/java/org/apache/camel/converter/IOConverterTest.java
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/converter/IOConverter.java
URL:
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/converter/IOConverter.java?rev=1222006&r1=1222005&r2=1222006&view=diff
==============================================================================
---
camel/trunk/camel-core/src/main/java/org/apache/camel/converter/IOConverter.java
(original)
+++
camel/trunk/camel-core/src/main/java/org/apache/camel/converter/IOConverter.java
Thu Dec 22 02:37:19 2011
@@ -154,6 +154,11 @@ public final class IOConverter {
return toInputStream(text.getBytes(IOHelper.getCharsetName(exchange)));
}
+ @Converter
+ public static InputStream toInputStream(StringBuffer buffer, Exchange
exchange) throws IOException {
+ return toInputStream(buffer.toString(), exchange);
+ }
+
/**
* @deprecated will be removed in Camel 3.0. Use the method which has 2
parameters.
*/
Modified:
camel/trunk/camel-core/src/test/java/org/apache/camel/converter/IOConverterTest.java
URL:
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/test/java/org/apache/camel/converter/IOConverterTest.java?rev=1222006&r1=1222005&r2=1222006&view=diff
==============================================================================
---
camel/trunk/camel-core/src/test/java/org/apache/camel/converter/IOConverterTest.java
(original)
+++
camel/trunk/camel-core/src/test/java/org/apache/camel/converter/IOConverterTest.java
Thu Dec 22 02:37:19 2011
@@ -104,6 +104,15 @@ public class IOConverterTest extends Con
InputStream is = IOConverter.toInputStream("Hello World", exchange);
assertNotNull(is);
}
+
+ public void testToInputStreamStringBufferExchange() throws Exception {
+ Exchange exchange = new DefaultExchange(context);
+ exchange.setProperty(Exchange.CHARSET_NAME,
ObjectHelper.getDefaultCharacterSet());
+ StringBuffer buffer = new StringBuffer();
+ buffer.append("Hello World");
+ InputStream is = IOConverter.toInputStream(buffer, exchange);
+ assertNotNull(is);
+ }
public void testToInputStreamBufferReader() throws Exception {
Exchange exchange = new DefaultExchange(context);