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);


Reply via email to