Updated Branches: refs/heads/camel-2.10.x 46a55b302 -> f4d4b8610
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/f4d4b861 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/f4d4b861 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/f4d4b861 Branch: refs/heads/camel-2.10.x Commit: f4d4b86102c658de1ca84992c34e379901498cba Parents: 46a55b3 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:38 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/f4d4b861/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 {
