Author: davsclaus
Date: Wed Jul 14 15:04:01 2010
New Revision: 964074
URL: http://svn.apache.org/viewvc?rev=964074&view=rev
Log:
CAMEL-2947: Fixed unit test due returning wrapped input stream now.
Modified:
camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HandlerTest.java
Modified:
camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HandlerTest.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HandlerTest.java?rev=964074&r1=964073&r2=964074&view=diff
==============================================================================
---
camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HandlerTest.java
(original)
+++
camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HandlerTest.java
Wed Jul 14 15:04:01 2010
@@ -17,7 +17,7 @@
package org.apache.camel.component.jetty;
import java.io.BufferedReader;
-import java.io.ByteArrayInputStream;
+import java.io.InputStream;
import java.io.InputStreamReader;
import org.apache.camel.Exchange;
@@ -42,8 +42,7 @@ public class HandlerTest extends CamelTe
assertEquals(0, statisticsHandler2.getRequests());
assertEquals(0, statisticsHandler3.getRequests());
- ByteArrayInputStream html = (ByteArrayInputStream) template
- .requestBody("http://localhost:9080/", "");
+ InputStream html = (InputStream)
template.requestBody("http://localhost:9080/", "");
BufferedReader br = new BufferedReader(new InputStreamReader(html));
assertEquals(htmlResponse, br.readLine());
@@ -59,8 +58,7 @@ public class HandlerTest extends CamelTe
assertEquals(0, statisticsHandler2.getRequests());
assertEquals(0, statisticsHandler3.getRequests());
- ByteArrayInputStream html = (ByteArrayInputStream)
template.requestBody(
- "http://localhost:9081/", "");
+ InputStream html = (InputStream)
template.requestBody("http://localhost:9081/", "");
BufferedReader br = new BufferedReader(new InputStreamReader(html));
assertEquals(htmlResponse, br.readLine());
@@ -84,16 +82,14 @@ public class HandlerTest extends CamelTe
public void configure() throws Exception {
from("jetty:http://localhost:9080/?handlers=#statisticsHandler1")
.process(new Processor() {
- public void process(Exchange exchange)
- throws Exception {
+ public void process(Exchange exchange) throws
Exception {
exchange.getOut().setBody(htmlResponse);
}
});
- from(
-
"jetty:http://localhost:9081/?handlers=#statisticsHandler2,#statisticsHandler3")
+
+
from("jetty:http://localhost:9081/?handlers=#statisticsHandler2,#statisticsHandler3")
.process(new Processor() {
- public void process(Exchange exchange)
- throws Exception {
+ public void process(Exchange exchange) throws
Exception {
exchange.getOut().setBody(htmlResponse);
}
});