Updated Branches: refs/heads/camel-2.11.x 77e49c6bf -> 28f4f9a11
CAMEL-6375 added unit test for it Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/28f4f9a1 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/28f4f9a1 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/28f4f9a1 Branch: refs/heads/camel-2.11.x Commit: 28f4f9a1176bb967184e2f149ffc93ade700206e Parents: 77e49c6 Author: Willem Jiang <[email protected]> Authored: Fri May 17 20:44:41 2013 +0800 Committer: Willem Jiang <[email protected]> Committed: Fri May 17 20:49:03 2013 +0800 ---------------------------------------------------------------------- .../camel/component/jetty/HttpRouteTest.java | 12 ++++++++++++ 1 files changed, 12 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/28f4f9a1/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRouteTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRouteTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRouteTest.java index d45038e..adb78c7 100644 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRouteTest.java +++ b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRouteTest.java @@ -34,6 +34,7 @@ import org.apache.camel.component.mock.MockEndpoint; import org.apache.camel.converter.stream.InputStreamCache; import org.apache.commons.httpclient.HttpClient; import org.apache.commons.httpclient.NameValuePair; +import org.apache.commons.httpclient.methods.GetMethod; import org.apache.commons.httpclient.methods.PostMethod; import org.apache.commons.httpclient.methods.PutMethod; import org.apache.commons.httpclient.methods.StringRequestEntity; @@ -160,6 +161,15 @@ public class HttpRouteTest extends BaseJettyTest { in, Exchange.CONTENT_TYPE, "application/txt", String.class); assertEquals("Got a wrong response.", fileSize, response.length()); } + + @Test + public void testResponseCode() throws Exception { + HttpClient client = new HttpClient(); + GetMethod get = new GetMethod("http://localhost:"; + port1 + "/responseCode"); + client.executeMethod(get); + // just make sure we get the right + assertEquals("Get a wrong status code.", 400, get.getStatusCode()); + } protected void invokeHttpEndpoint() throws IOException { @@ -194,6 +204,8 @@ public class HttpRouteTest extends BaseJettyTest { exchange.getOut().setBody("<b>Hello World</b>"); } }; + + from("jetty:http://localhost:"; + port1 + "/responseCode").setHeader(Exchange.HTTP_RESPONSE_CODE, simple("400")); Processor printProcessor = new Processor() { public void process(Exchange exchange) throws Exception {
