Author: ningjiang
Date: Fri Jun 29 03:26:49 2012
New Revision: 1355226
URL: http://svn.apache.org/viewvc?rev=1355226&view=rev
Log:
Fix the build error of StreamSystemOutTest
Modified:
camel/branches/camel-2.9.x/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamSystemOutTest.java
Modified:
camel/branches/camel-2.9.x/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamSystemOutTest.java
URL:
http://svn.apache.org/viewvc/camel/branches/camel-2.9.x/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamSystemOutTest.java?rev=1355226&r1=1355225&r2=1355226&view=diff
==============================================================================
---
camel/branches/camel-2.9.x/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamSystemOutTest.java
(original)
+++
camel/branches/camel-2.9.x/components/camel-stream/src/test/java/org/apache/camel/component/stream/StreamSystemOutTest.java
Fri Jun 29 03:26:49 2012
@@ -16,6 +16,9 @@
*/
package org.apache.camel.component.stream;
+import java.io.ByteArrayOutputStream;
+import java.io.PrintStream;
+
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.test.junit4.CamelTestSupport;
import org.junit.Test;
@@ -25,15 +28,43 @@ import org.junit.Test;
*/
public class StreamSystemOutTest extends CamelTestSupport {
+ String message = "Hello World";
+
+ PrintStream stdOut = System.out;
+
+ ByteArrayOutputStream mockOut = new ByteArrayOutputStream();
+
// START SNIPPET: e1
- @Test
+ @Test
public void testStringContent() throws Exception {
- template.sendBody("direct:in", "Hello Text World\n");
+ try {
+ // Given
+ System.setOut(new PrintStream(mockOut));
+
+ // When
+ template.sendBody("direct:in", message);
+
+ // Then
+ assertEquals(message + "\n", new String(mockOut.toByteArray()));
+ } finally {
+ System.setOut(stdOut);
+ }
}
@Test
public void testBinaryContent() {
- template.sendBody("direct:in", "Hello Bytes World\n".getBytes());
+ try {
+ // Given
+ System.setOut(new PrintStream(mockOut));
+
+ // When
+ template.sendBody("direct:in", message.getBytes());
+
+ // Then
+ assertEquals(message, new String(mockOut.toByteArray()));
+ } finally {
+ System.setOut(stdOut);
+ }
}
@Test
