camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cschnei...@apache.org
Subject [18/24] camel git commit: CAMEL-8239 Split jetty8 and jetty9 support into separate modules
Date Mon, 19 Jan 2015 13:44:32 GMT
http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpHeaderTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpHeaderTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpHeaderTest.java
deleted file mode 100644
index c3deb50..0000000
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpHeaderTest.java
+++ /dev/null
@@ -1,95 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jetty;
-
-import java.util.Map;
-import java.util.Map.Entry;
-import javax.servlet.ServletRequest;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.builder.RouteBuilder;
-import org.junit.Test;
-
-public class HttpHeaderTest extends BaseJettyTest {
-
-    @Test
-    public void testHttpHeaders() throws Exception {
-        String result = template.requestBody("direct:start", "hello", String.class);
-        assertEquals("Should send a right http header to the server.", "Find the key!", result);
-    }
-    
-    @Test
-    public void testServerHeader() throws Exception {
-        Exchange ex = template.request("http://localhost:{{port}}/server/mytest", new Processor() {
-            @Override
-            public void process(Exchange exchange) throws Exception {
-                // Do nothing here
-            }
-        });
-        
-        assertNotNull(ex.getOut().getHeader("Server"));
-        assertNull(ex.getOut().getHeader("Date"));
-        
-        ex = template.request("http://localhost:{{port2}}/server/mytest", new Processor() {
-            @Override
-            public void process(Exchange exchange) throws Exception {
-                // Do nothing here
-            }
-        });
-        
-        assertNull(ex.getOut().getHeader("Server"));
-        assertNotNull(ex.getOut().getHeader("Date"));
-    }
-    
-   
-    @Override
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
-            public void configure() throws Exception {
-                from("direct:start").setHeader("SOAPAction", constant("http://xxx.com/interfaces/ticket"))
-                    .setHeader("Content-Type", constant("text/xml; charset=utf-8"))
-                    .setHeader(Exchange.HTTP_PROTOCOL_VERSION, constant("HTTP/1.0"))
-                    .to("http://localhost:{{port}}/myapp/mytest");
-
-                from("jetty:http://localhost:{{port}}/myapp/mytest").process(new Processor() {
-                    public void process(Exchange exchange) throws Exception {
-                        Map<String, Object> headers = exchange.getIn().getHeaders();
-                        ServletRequest request = exchange.getIn().getHeader(Exchange.HTTP_SERVLET_REQUEST, ServletRequest.class);
-                        assertNotNull(request);
-                        assertEquals("Get a wong http protocol version", request.getProtocol(), "HTTP/1.0");
-                        for (Entry<String, Object> entry : headers.entrySet()) {
-                            if ("SOAPAction".equals(entry.getKey()) && "http://xxx.com/interfaces/ticket".equals(entry.getValue())) {
-                                exchange.getOut().setBody("Find the key!");
-                                return;
-                            }
-                        }
-                        exchange.getOut().setBody("Cannot find the key!");
-                    }
-                });
-                
-                from("jetty:http://localhost:{{port}}/server/mytest").transform(constant("Response!"));
-                
-                //The setting only effect on a new server endpoint
-                from("jetty:http://localhost:{{port2}}/server/mytest?sendServerVersion=false&sendDateHeader=true").transform(constant("Response!"));
-                
-               
-            }
-        };
-    }
-
-}

http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpMethodRestrictTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpMethodRestrictTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpMethodRestrictTest.java
deleted file mode 100644
index 8ff3990..0000000
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpMethodRestrictTest.java
+++ /dev/null
@@ -1,74 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jetty;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.Message;
-import org.apache.camel.Processor;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.commons.httpclient.HttpClient;
-import org.apache.commons.httpclient.methods.GetMethod;
-import org.apache.commons.httpclient.methods.PostMethod;
-import org.apache.commons.httpclient.methods.StringRequestEntity;
-import org.junit.Test;
-
-public class HttpMethodRestrictTest extends BaseJettyTest {
-
-    private String getUrl() {
-        return "http://localhost:" + getPort() + "/methodRestrict";
-    }
-    
-    @Test
-    public void testProperHttpMethod() throws Exception {
-        HttpClient httpClient = new HttpClient();
-        PostMethod httpPost = new PostMethod(getUrl());
-
-        StringRequestEntity reqEntity = new StringRequestEntity("This is a test", null, null);
-        httpPost.setRequestEntity(reqEntity);
-
-        int status = httpClient.executeMethod(httpPost);
-
-        assertEquals("Get a wrong response status", 200, status);
-
-        String result = httpPost.getResponseBodyAsString();
-        assertEquals("Get a wrong result", "This is a test response", result);
-    }
-
-    @Test
-    public void testImproperHttpMethod() throws Exception {
-        HttpClient httpClient = new HttpClient();
-        GetMethod httpGet = new GetMethod(getUrl());
-        int status = httpClient.executeMethod(httpGet);
-
-        assertEquals("Get a wrong response status", 405, status);
-    }
-    
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
-            public void configure() throws Exception {
-                                
-                from("jetty://http://localhost:{{port}}/methodRestrict?httpMethodRestrict=POST").process(new Processor() {
-                    public void process(Exchange exchange) throws Exception {
-                        Message in = exchange.getIn();
-                        String request = in.getBody(String.class);
-                        exchange.getOut().setBody(request + " response");
-                    }
-                });
-            }
-        };
-    }
-}

http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpOperationsFailedExceptionUriTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpOperationsFailedExceptionUriTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpOperationsFailedExceptionUriTest.java
deleted file mode 100644
index cc48438..0000000
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpOperationsFailedExceptionUriTest.java
+++ /dev/null
@@ -1,57 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jetty;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.RuntimeCamelException;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.http.HttpOperationFailedException;
-import org.junit.Test;
-
-/**
- * @version 
- */
-public class HttpOperationsFailedExceptionUriTest extends BaseJettyTest {
-
-    @Test
-    public void testHttpOperationsFailedExceptionUri() throws Exception {
-        try {
-            template.requestBodyAndHeader("http://localhost:{{port}}/foo?bar=123", null, "foo", 123);
-            fail("Should have thrown an exception");
-        } catch (RuntimeCamelException e) {
-            HttpOperationFailedException cause = assertIsInstanceOf(HttpOperationFailedException.class, e.getCause());
-            assertEquals(500, cause.getStatusCode());
-            assertEquals("http://localhost:" + getPort() + "/foo?bar=123", cause.getUri());
-        }
-    }
-
-    @Override
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
-            @Override
-            public void configure() throws Exception {
-                from("jetty://http://localhost:{{port}}/foo")
-                    .process(new Processor() {
-                        public void process(Exchange exchange) throws Exception {
-                            exchange.getOut().setHeader(Exchange.HTTP_RESPONSE_CODE, 500);
-                        }
-                    });
-            }
-        };
-    }
-}

http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpPollingConsumerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpPollingConsumerTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpPollingConsumerTest.java
deleted file mode 100644
index 41f1c59..0000000
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpPollingConsumerTest.java
+++ /dev/null
@@ -1,63 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jetty;
-
-import java.net.SocketTimeoutException;
-
-import org.apache.camel.RuntimeCamelException;
-import org.apache.camel.builder.RouteBuilder;
-import org.junit.Test;
-
-/**
- * @version 
- */
-public class HttpPollingConsumerTest extends BaseJettyTest {
-
-    @Test
-    public void testReceive() throws Exception {
-        String body = consumer.receiveBody("http://localhost:{{port}}/test", String.class);
-        assertEquals("Bye World", body);
-    }
-
-    @Test
-    public void testReceiveTimeout() throws Exception {
-        String body = consumer.receiveBody("http://localhost:{{port}}/test", 5000, String.class);
-        assertEquals("Bye World", body);
-    }
-
-    @Test
-    public void testReceiveTimeoutTriggered() throws Exception {
-        try {
-            consumer.receiveBody("http://localhost:{{port}}/test", 250, String.class);
-            fail("Should have thrown an exception");
-        } catch (RuntimeCamelException e) {
-            assertIsInstanceOf(SocketTimeoutException.class, e.getCause());
-        }
-    }
-
-    @Override
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
-            @Override
-            public void configure() throws Exception {
-                from("jetty://http://localhost:{{port}}/test")
-                    .delay(2000).transform(constant("Bye World"));
-            }
-        };
-    }
-
-}

http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpPollingGetTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpPollingGetTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpPollingGetTest.java
deleted file mode 100644
index 9e3a3cf..0000000
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpPollingGetTest.java
+++ /dev/null
@@ -1,76 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jetty;
-
-import java.util.List;
-import java.util.Map;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.Message;
-import org.apache.camel.Processor;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.Test;
-
-/**
- * @version 
- */
-public class HttpPollingGetTest extends BaseJettyTest {
-
-    protected String expectedText = "<html";
-
-    @Test
-    public void testHttpPollingGet() throws Exception {
-        MockEndpoint mockEndpoint = resolveMandatoryEndpoint("mock:results", MockEndpoint.class);
-        mockEndpoint.expectedMinimumMessageCount(1);
-
-        mockEndpoint.assertIsSatisfied();
-        List<Exchange> list = mockEndpoint.getReceivedExchanges();
-        Exchange exchange = list.get(0);
-        assertNotNull("exchange", exchange);
-
-        Message in = exchange.getIn();
-        assertNotNull("in", in);
-
-        Map<String, Object> headers = in.getHeaders();
-
-        log.debug("Headers: " + headers);
-        assertTrue("Should be more than one header but was: " + headers, headers.size() > 0);
-
-        String body = in.getBody(String.class);
-
-        log.debug("Body: " + body);
-        assertNotNull("Should have a body!", body);
-        assertTrue("body should contain: " + expectedText, body.contains(expectedText));
-    }
-
-    @Override
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
-            public void configure() {
-                from("http://localhost:{{port}}/myservice?delay=5000").to("mock:results");
-
-                from("jetty:http://localhost:{{port}}/myservice").process(new Processor() {
-                    public void process(Exchange exchange) throws Exception {
-                        exchange.getOut().setBody("<html>Bye World</html>");
-                    }
-                });
-            }
-        };
-    }
-
-}

http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerByteTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerByteTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerByteTest.java
deleted file mode 100644
index a03986d..0000000
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerByteTest.java
+++ /dev/null
@@ -1,44 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jetty;
-
-import org.apache.camel.builder.RouteBuilder;
-import org.junit.Test;
-
-/**
- * @version 
- */
-public class HttpProducerByteTest extends BaseJettyTest {
-
-    @Test
-    public void testHttpProducerByteTest() throws Exception {
-        byte[] data = "Hello World".getBytes();
-        String out = template.requestBody("http://localhost:{{port}}/test", data, String.class);
-        assertEquals("Bye World", out);
-    }
-
-    @Override
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
-            @Override
-            public void configure() throws Exception {
-                from("jetty://http://localhost:{{port}}/test").transform(constant("Bye World"));
-            }
-        };
-    }
-
-}

http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerConcurrentTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerConcurrentTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerConcurrentTest.java
deleted file mode 100644
index a9361eb..0000000
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerConcurrentTest.java
+++ /dev/null
@@ -1,92 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jetty;
-
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.Map;
-import java.util.Set;
-import java.util.concurrent.Callable;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import java.util.concurrent.Future;
-
-import org.apache.camel.builder.RouteBuilder;
-import org.junit.Test;
-
-/**
- * HTTP producer concurrent test.
- *
- * @version 
- */
-public class HttpProducerConcurrentTest extends BaseJettyTest {
-
-    @Test
-    public void testNoConcurrentProducers() throws Exception {
-        doSendMessages(1, 1);
-    }
-
-    @Test
-    public void testConcurrentProducers() throws Exception {
-        doSendMessages(10, 5);
-    }
-
-    private void doSendMessages(int files, int poolSize) throws Exception {
-        getMockEndpoint("mock:result").expectedMessageCount(files);
-        getMockEndpoint("mock:result").assertNoDuplicates(body());
-
-        ExecutorService executor = Executors.newFixedThreadPool(poolSize);
-        // we access the responses Map below only inside the main thread,
-        // so no need for a thread-safe Map implementation
-        Map<Integer, Future<String>> responses = new HashMap<Integer, Future<String>>();
-        for (int i = 0; i < files; i++) {
-            final int index = i;
-            Future<String> out = executor.submit(new Callable<String>() {
-                public String call() throws Exception {
-                    return template.requestBody("http://localhost:{{port}}/echo", "" + index, String.class);
-                }
-            });
-            responses.put(index, out);
-        }
-
-        assertMockEndpointsSatisfied();
-
-        assertEquals(files, responses.size());
-
-        // get all responses
-        Set<String> unique = new HashSet<String>();
-        for (Future<String> future : responses.values()) {
-            unique.add(future.get());
-        }
-
-        // should be 'files' unique responses
-        assertEquals("Should be " + files + " unique responses", files, unique.size());
-        executor.shutdownNow();
-    }
-
-
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
-            public void configure() throws Exception {
-                // expose a echo service
-                from("jetty:http://localhost:{{port}}/echo")
-                    .transform(body().append(body())).to("mock:result");
-            }
-        };
-    }
-
-}

http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerJMXBeansIssueTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerJMXBeansIssueTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerJMXBeansIssueTest.java
deleted file mode 100644
index 15a71a2..0000000
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerJMXBeansIssueTest.java
+++ /dev/null
@@ -1,80 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jetty;
-
-import org.apache.camel.Endpoint;
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.Producer;
-import org.apache.camel.builder.RouteBuilder;
-import org.junit.Test;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * @version 
- */
-public class HttpProducerJMXBeansIssueTest extends BaseJettyTest {
-
-    private static final Logger LOG = LoggerFactory.getLogger(HttpProducerJMXBeansIssueTest.class);
-
-    @Override
-    public void setUp() throws Exception {
-        // to enable the JMX connector
-        enableJMX();
-        System.setProperty("org.apache.camel.jmx.createRmiConnector", "True");
-        super.setUp();
-    }
-
-    @Override
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
-            @Override
-            public void configure() throws Exception {
-                from("jetty:http://localhost:{{port}}/leak").transform(constant("Bye World"));
-
-                from("direct:leak").process(new Processor() {
-                    public void process(Exchange exchange) throws Exception {
-                        LOG.debug("URL is: " + exchange.getIn().getHeader("url"));
-                    }
-                }).recipientList(header("url"));
-            }
-        };
-    }
-
-    @Test
-    public void testNothing() {
-        // do nothing as this test is manual
-    }
-
-    // @Test
-    // TODO: disabled as this is a manual test
-    public void testSendAlot() throws Exception {
-        Endpoint ep = context.getEndpoint("direct:leak");
-        Producer p = ep.createProducer();
-        p.start();
-
-        for (int i = 0; i < 10000; i++) {
-            Exchange ex = ep.createExchange();
-            ex.getIn().setHeader("url", "http://localhost:{{port}}/leak?id=" + i);
-            p.process(ex);
-        }
-
-        p.stop();
-    }
-
-}

http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerQueryParamTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerQueryParamTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerQueryParamTest.java
deleted file mode 100644
index b98a554..0000000
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerQueryParamTest.java
+++ /dev/null
@@ -1,78 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jetty;
-
-import java.util.Map;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.builder.RouteBuilder;
-import org.junit.Test;
-
-/**
- * @version 
- */
-public class HttpProducerQueryParamTest extends BaseJettyTest {
-
-    private String url = "http://0.0.0.0:" + getPort() + "/cheese";
-
-    @Test
-    public void testQueryParameters() throws Exception {
-        Exchange exchange = template.request(url + "?quote=Camel%20rocks", null);
-        assertNotNull(exchange);
-
-        String body = exchange.getOut().getBody(String.class);
-        Map<?, ?> headers = exchange.getOut().getHeaders();
-
-        assertEquals("Bye World", body);
-        assertEquals("Carlsberg", headers.get("beer"));
-    }
-
-    @Test
-    public void testQueryParametersWithHeader() throws Exception {
-        Exchange exchange = template.request(url, new Processor() {
-            public void process(Exchange exchange) throws Exception {
-                exchange.getIn().setHeader(Exchange.HTTP_QUERY, "quote=Camel rocks");
-            }
-        });
-        assertNotNull(exchange);
-
-        String body = exchange.getOut().getBody(String.class);
-        Map<?, ?> headers = exchange.getOut().getHeaders();
-
-        assertEquals("Bye World", body);
-        assertEquals("Carlsberg", headers.get("beer"));
-    }
-
-    @Override
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
-            @Override
-            public void configure() throws Exception {
-                from("jetty:" + url).process(new Processor() {
-                    public void process(Exchange exchange) throws Exception {
-                        String quote = exchange.getIn().getHeader("quote", String.class);
-                        assertEquals("Camel rocks", quote);
-
-                        exchange.getOut().setBody("Bye World");
-                        exchange.getOut().setHeader("beer", "Carlsberg");
-                    }
-                });
-            }
-        };
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerSOTimeoutTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerSOTimeoutTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerSOTimeoutTest.java
deleted file mode 100644
index bf39a54..0000000
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerSOTimeoutTest.java
+++ /dev/null
@@ -1,72 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jetty;
-
-import java.net.SocketTimeoutException;
-
-import org.apache.camel.RuntimeCamelException;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.Test;
-
-/**
- * Unit test for using http client SO timeout
- *
- * @version 
- */
-public class HttpProducerSOTimeoutTest extends BaseJettyTest {
-
-    @Test
-    public void testSendWithSOTimeoutNoTimeout() throws Exception {
-        MockEndpoint mock = getMockEndpoint("mock:result");
-        mock.expectedMessageCount(1);
-
-        String out = template.requestBody("http://localhost:{{port}}/myservice?httpClient.soTimeout=5000", null, String.class);
-        assertEquals("Bye World", out);
-
-        assertMockEndpointsSatisfied();
-    }
-    
-    @Test
-    public void testSendWithSOTimeoutTimeout() throws Exception {
-        MockEndpoint mock = getMockEndpoint("mock:result");
-        mock.expectedMessageCount(1);
-
-        try {
-            // we use a timeout of 1 second
-            template.requestBody("http://localhost:{{port}}/myservice?httpClient.soTimeout=1000", null, String.class);
-            fail("Should throw an exception");
-        } catch (RuntimeCamelException e) {
-            assertIsInstanceOf(SocketTimeoutException.class, e.getCause());
-        }
-
-        assertMockEndpointsSatisfied();
-    }
-
-    @Override
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
-            @Override
-            public void configure() throws Exception {
-                from("jetty://http://localhost:{{port}}/myservice")
-                    // but we wait for 2 sec before reply is sent back
-                    .delay(2000)
-                    .transform().constant("Bye World").to("mock:result");
-            }
-        };
-    }
-}

http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerSendEmptyHeaderTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerSendEmptyHeaderTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerSendEmptyHeaderTest.java
deleted file mode 100644
index 10b795c..0000000
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerSendEmptyHeaderTest.java
+++ /dev/null
@@ -1,54 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jetty;
-
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.Test;
-
-/**
- *
- */
-public class HttpProducerSendEmptyHeaderTest extends BaseJettyTest {
-
-    @Test
-    public void testHttpProducerSendEmptyHeader() throws Exception {
-        MockEndpoint mock = getMockEndpoint("mock:result");
-        mock.expectedMessageCount(1);
-        
-        // Jetty 8 treats an empty header as "" while Jetty 9 treats it as null
-        String expectedValue = isJetty8() ? "" : null; 
-        mock.expectedHeaderReceived("foo", expectedValue);
-
-        template.sendBodyAndHeader("http://localhost:{{port}}/myapp/mytest", "Hello World", "foo", "");
-
-        assertMockEndpointsSatisfied();
-    }
-
-    @Override
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        allowNullHeaders();
-        return new RouteBuilder() {
-            @Override
-            public void configure() throws Exception {
-                from("jetty:http://localhost:{{port}}/myapp/mytest")
-                    .convertBodyTo(String.class)
-                    .to("mock:result");
-            }
-        };
-    }
-}

http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerTwoParametersWithSameKeyTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerTwoParametersWithSameKeyTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerTwoParametersWithSameKeyTest.java
deleted file mode 100644
index 0b03809..0000000
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProducerTwoParametersWithSameKeyTest.java
+++ /dev/null
@@ -1,103 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jetty;
-
-import java.util.ArrayList;
-import java.util.List;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.builder.RouteBuilder;
-import org.junit.Test;
-
-/**
- *
- */
-public class HttpProducerTwoParametersWithSameKeyTest extends BaseJettyTest {
-
-    @Test
-    public void testTwoParametersWithSameKey() throws Exception {
-        Exchange out = template.request("http://localhost:{{port}}/myapp?from=me&to=foo&to=bar", null);
-
-        assertNotNull(out);
-        assertFalse("Should not fail", out.isFailed());
-        assertEquals("OK", out.getOut().getBody(String.class));
-        assertEquals("yes", out.getOut().getHeader("bar"));
-
-        List<?> foo = out.getOut().getHeader("foo", List.class);
-        assertNotNull(foo);
-        assertEquals(2, foo.size());
-        assertEquals("123", foo.get(0));
-        assertEquals("456", foo.get(1));
-    }
-
-    @Test
-    public void testTwoHeadersWithSameKeyHeader() throws Exception {
-        Exchange out = template.request("http://localhost:{{port}}/myapp", new Processor() {
-            public void process(Exchange exchange) throws Exception {
-                exchange.getIn().setBody(null);
-                exchange.getIn().setHeader("from", "me");
-                List<String> list = new ArrayList<String>();
-                list.add("foo");
-                list.add("bar");
-                exchange.getIn().setHeader("to", list);
-            }
-        });
-
-        assertNotNull(out);
-        assertFalse("Should not fail", out.isFailed());
-        assertEquals("OK", out.getOut().getBody(String.class));
-        assertEquals("yes", out.getOut().getHeader("bar"));
-
-        List<?> foo = out.getOut().getHeader("foo", List.class);
-        assertNotNull(foo);
-        assertEquals(2, foo.size());
-        assertEquals("123", foo.get(0));
-        assertEquals("456", foo.get(1));
-    }
-
-    @Override
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
-            @Override
-            public void configure() throws Exception {
-                from("jetty://http://localhost:{{port}}/myapp").process(new Processor() {
-                    public void process(Exchange exchange) throws Exception {
-                        String from = exchange.getIn().getHeader("from", String.class);
-                        assertEquals("me", from);
-
-                        List<?> to = exchange.getIn().getHeader("to", List.class);
-                        assertNotNull(to);
-                        assertEquals(2, to.size());
-                        assertEquals("foo", to.get(0));
-                        assertEquals("bar", to.get(1));
-
-                        // response
-                        exchange.getOut().setBody("OK");
-                        // use multiple values for the foo header in the reply
-                        List<Integer> list = new ArrayList<Integer>();
-                        list.add(123);
-                        list.add(456);
-                        exchange.getOut().setHeader("foo", list);
-                        exchange.getOut().setHeader("bar", "yes");
-                    }
-                });
-            }
-        };
-    }
-
-}

http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProxyRouteContentTypeTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProxyRouteContentTypeTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProxyRouteContentTypeTest.java
deleted file mode 100644
index 7485a93..0000000
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProxyRouteContentTypeTest.java
+++ /dev/null
@@ -1,52 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jetty;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.util.ExchangeHelper;
-import org.junit.Test;
-
-public class HttpProxyRouteContentTypeTest extends BaseJettyTest {
-
-    @Test
-    public void testHttpProxyWithContentType() throws Exception {
-
-        String out = template.requestBodyAndHeader("http://localhost:{{port}}/hello", "test",  "Content-Type", "application/xml", String.class);
-
-        assertEquals("Get a wrong response ", "application/xml", out);
-    }
-
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
-            public void configure() {
-                from("jetty://http://localhost:{{port}}/hello").to("http://localhost:{{port}}/bye?throwExceptionOnFailure=false&bridgeEndpoint=true");
-
-                from("jetty://http://localhost:{{port}}/bye").process(new Processor() {
-
-                    public void process(Exchange exchange) throws Exception {
-
-                        exchange.getOut().setBody(ExchangeHelper.getContentType(exchange));
-                    }
-
-                });
-            }
-        };
-    }
-
-}

http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProxyRouteTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProxyRouteTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProxyRouteTest.java
deleted file mode 100644
index e0188f6..0000000
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpProxyRouteTest.java
+++ /dev/null
@@ -1,99 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jetty;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.Message;
-import org.apache.camel.Processor;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.util.StopWatch;
-import org.apache.camel.util.TimeUtils;
-import org.junit.Test;
-
-public class HttpProxyRouteTest extends BaseJettyTest {
-
-    private int size = 10;
-
-    @Test
-    public void testHttpProxy() throws Exception {
-        log.info("Sending " + size + " messages to a http endpoint which is proxied/bridged");
-
-        StopWatch watch = new StopWatch();
-        for (int i = 0; i < size; i++) {
-            String out = template.requestBody("http://localhost:{{port}}?foo=" + i, null, String.class);
-            assertEquals("Bye " + i, out);
-        }
-
-        log.info("Time taken: " + TimeUtils.printDuration(watch.taken()));
-    }
-    
-    @Test
-    public void testHttpProxyWithDifferentPath() throws Exception {
-        String out = template.requestBody("http://localhost:{{port}}/proxy", null, String.class);
-        assertEquals("/otherEndpoint", out);
-        
-        out = template.requestBody("http://localhost:{{port}}/proxy/path", null, String.class);
-        assertEquals("/otherEndpoint/path", out);
-    }
-    
-    @Test
-    public void testHttpProxyHostHeader() throws Exception {
-        String out = template.requestBody("http://localhost:{{port}}/proxyServer", null, String.class);
-        assertEquals("Get a wrong host header", "localhost:" + getPort2(), out);
-    }
-    
-    @Test
-    public void testHttpProxyFormHeader() throws Exception {
-        String out = template.requestBodyAndHeader("http://localhost:{{port}}/form", "username=abc&pass=password", Exchange.CONTENT_TYPE, "application/x-www-form-urlencoded", String.class);
-        assertEquals("Get a wrong response message", "username=abc&pass=password", out);
-    }
-
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
-            public void configure() {
-                from("jetty://http://localhost:{{port}}")
-                    .to("http://localhost:{{port}}/bye?throwExceptionOnFailure=false&bridgeEndpoint=true");
-                
-                from("jetty://http://localhost:{{port}}/proxy?matchOnUriPrefix=true")
-                    .to("http://localhost:{{port}}/otherEndpoint?throwExceptionOnFailure=false&bridgeEndpoint=true");
-
-                from("jetty://http://localhost:{{port}}/bye").transform(header("foo").prepend("Bye "));
-                
-                from("jetty://http://localhost:{{port}}/otherEndpoint?matchOnUriPrefix=true").transform(header(Exchange.HTTP_URI));
-                
-                from("jetty://http://localhost:{{port}}/proxyServer")
-                    .to("http://localhost:{{port2}}/host?bridgeEndpoint=true");
-                
-                from("jetty://http://localhost:{{port2}}/host").transform(header("host"));
-                
-                // check the from request
-                from("jetty://http://localhost:{{port}}/form?bridgeEndpoint=true")
-                    .process(new Processor() {
-                        @Override
-                        public void process(Exchange exchange) throws Exception {
-                            // just take out the message body and send it back
-                            Message in = exchange.getIn();
-                            String request = in.getBody(String.class);
-                            exchange.getOut().setBody(request);
-                        }
-                        
-                    });
-            }
-        };
-    }    
-
-}

http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRedirectNoLocationTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRedirectNoLocationTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRedirectNoLocationTest.java
deleted file mode 100644
index b37b448..0000000
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRedirectNoLocationTest.java
+++ /dev/null
@@ -1,59 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jetty;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.RuntimeCamelException;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.http.HttpOperationFailedException;
-import org.junit.Test;
-
-/**
- * @version 
- */
-public class HttpRedirectNoLocationTest extends BaseJettyTest {
-
-    @Test
-    public void testHttpRedirectNoLocation() throws Exception {
-        try {
-            template.requestBody("http://localhost:{{port}}/test", "Hello World", String.class);
-            fail("Should have thrown an exception");
-        } catch (RuntimeCamelException e) {
-            HttpOperationFailedException cause = assertIsInstanceOf(HttpOperationFailedException.class, e.getCause());
-            assertEquals(302, cause.getStatusCode());
-            assertEquals(true, cause.isRedirectError());
-            assertEquals(false, cause.hasRedirectLocation());
-            assertEquals(null, cause.getRedirectLocation());
-        }
-    }
-
-    @Override
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
-            @Override
-            public void configure() throws Exception {
-                from("jetty://http://localhost:{{port}}/test")
-                    .process(new Processor() {
-                        public void process(Exchange exchange) throws Exception {
-                            exchange.getOut().setHeader(Exchange.HTTP_RESPONSE_CODE, 302);
-                        }
-                    });
-            }
-        };
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRedirectTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRedirectTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRedirectTest.java
deleted file mode 100644
index cd26dae..0000000
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRedirectTest.java
+++ /dev/null
@@ -1,89 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jetty;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.RuntimeCamelException;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.http.HttpOperationFailedException;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.junit.Test;
-
-/**
- * @version
- */
-public class HttpRedirectTest extends BaseJettyTest {
-
-    @Test
-    public void testHttpRedirect() throws Exception {
-        try {
-            template.requestBody("http://localhost:{{port}}/test", "Hello World", String.class);
-            fail("Should have thrown an exception");
-        } catch (RuntimeCamelException e) {
-            HttpOperationFailedException cause = assertIsInstanceOf(HttpOperationFailedException.class,
-                                                                    e.getCause());
-            assertEquals(301, cause.getStatusCode());
-            assertEquals(true, cause.isRedirectError());
-            assertEquals(true, cause.hasRedirectLocation());
-            assertEquals("http://localhost:" + getPort() + "/test", cause.getUri());
-            assertEquals("http://localhost:" + getPort() + "/newtest", cause.getRedirectLocation());
-        }
-    }
-
-    @Test
-    public void testHttpRedirectFromCamelRoute() throws Exception {
-        MockEndpoint errorEndpoint = context.getEndpoint("mock:error", MockEndpoint.class);
-        errorEndpoint.expectedMessageCount(1);
-        MockEndpoint resultEndpoint = context.getEndpoint("mock:result", MockEndpoint.class);
-        resultEndpoint.expectedMessageCount(0);
-        try {
-            template.requestBody("direct:start", "Hello World", String.class);
-            fail("Should have thrown an exception");
-        } catch (RuntimeCamelException e) {
-            HttpOperationFailedException cause = assertIsInstanceOf(HttpOperationFailedException.class,
-                                                                    e.getCause());
-            assertEquals(302, cause.getStatusCode());
-        }
-        errorEndpoint.assertIsSatisfied();
-        resultEndpoint.assertIsSatisfied();
-    }
-
-    @Override
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
-            @Override
-            public void configure() throws Exception {
-                from("jetty://http://localhost:{{port}}/test").process(new Processor() {
-                    public void process(Exchange exchange) throws Exception {
-                        exchange.getOut().setHeader(Exchange.HTTP_RESPONSE_CODE, 301);
-                        exchange.getOut().setHeader("location", "http://localhost:" + getPort() + "/newtest");
-                    }
-                });
-                from("jetty://http://localhost:{{port}}/remove").process(new Processor() {
-                    public void process(Exchange exchange) throws Exception {
-                        exchange.getOut().setHeader(Exchange.HTTP_RESPONSE_CODE, 302);
-                    }
-                });
-                
-                from("direct:start").onException(HttpOperationFailedException.class).to("mock:error").end()
-                    .to("http://localhost:{{port}}/remove?throwExceptionOnFailure=true").to("mock:result");
-
-            }
-        };
-    }
-}

http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRequestResponseTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRequestResponseTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRequestResponseTest.java
deleted file mode 100644
index 7c962c2..0000000
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRequestResponseTest.java
+++ /dev/null
@@ -1,81 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jetty;
-
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.http.HttpMessage;
-import org.junit.Test;
-
-/**
- * Unit test for request response in message
- */
-public class HttpRequestResponseTest extends BaseJettyTest {
-
-    @Test
-    public void testHttpServletRequestResponse() throws Exception {
-        Object response = template.requestBody("http://localhost:{{port}}/myapp/myservice", "bookid=123");
-        // convert the response to a String
-        String body = context.getTypeConverter().convertTo(String.class, response);
-        assertEquals("Written by servlet response<html><body>Book 123 is Camel in Action</body></html>", body);
-    }
-
-    @Override
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
-            public void configure() throws Exception {
-                // START SNIPPET: e1
-                from("jetty:http://localhost:{{port}}/myapp/myservice").process(new MyBookService());
-                // END SNIPPET: e1
-            }
-        };
-    }
-
-    public class MyBookService implements Processor {
-        public void process(Exchange exchange) throws Exception {
-            // just get the body as a string
-            String body = exchange.getIn().getBody(String.class);
-
-            // we have access to the HttpServletRequest here and we can grab it if we need it
-            HttpServletRequest req = exchange.getIn().getBody(HttpServletRequest.class);
-            assertNotNull(req);
-
-            // we have access to the HttpServletResponse here and we can grab it if we need it
-            HttpServletResponse res = exchange.getIn().getBody(HttpServletResponse.class);
-            assertNotNull(res);
-
-            // and they should also be on HttpMessage
-            HttpMessage msg = (HttpMessage) exchange.getIn();
-            assertNotNull(msg.getRequest());
-            assertNotNull(msg.getResponse());
-
-            // and we can use servlet response to write to output stream also
-            res.getOutputStream().print("Written by servlet response");
-
-            // for unit testing
-            assertEquals("bookid=123", body);
-
-            // send a html response
-            exchange.getOut().setBody("<html><body>Book 123 is Camel in Action</body></html>");
-        }
-    }
-
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpReturnDataNotInputStreamConvertableTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpReturnDataNotInputStreamConvertableTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpReturnDataNotInputStreamConvertableTest.java
deleted file mode 100644
index c057e18..0000000
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpReturnDataNotInputStreamConvertableTest.java
+++ /dev/null
@@ -1,56 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jetty;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.builder.RouteBuilder;
-import org.junit.Test;
-
-/**
- * @version 
- */
-public class HttpReturnDataNotInputStreamConvertableTest extends BaseJettyTest {
-
-    @Test
-    public void testHttpReturnDataNotInputStreamConvertableTest() throws Exception {
-        String out = template.requestBody("http://localhost:{{port}}/test", "Hello World", String.class);
-        assertEquals("This is the response", out);
-    }
-
-    @Override
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
-            @Override
-            public void configure() throws Exception {
-                from("jetty://http://localhost:{{port}}/test")
-                    .process(new Processor() {
-                        public void process(Exchange exchange) throws Exception {
-                            exchange.getOut().setBody(new MyResponseBean());
-                        }
-                    });
-            }
-        };
-    }
-
-    private static class MyResponseBean {
-        @Override
-        public String toString() {
-            return "This is the response";
-        }
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpReturnFaultTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpReturnFaultTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpReturnFaultTest.java
deleted file mode 100644
index 86f2e85..0000000
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpReturnFaultTest.java
+++ /dev/null
@@ -1,61 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jetty;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.http.HttpOperationFailedException;
-import org.junit.Test;
-
-/**
- * @version
- */
-public class HttpReturnFaultTest extends BaseJettyTest {
-
-    @Test
-    public void testHttpFault() throws Exception {
-        Exchange exchange = template.request("http://localhost:{{port}}/test", new Processor() {
-            @Override
-            public void process(Exchange exchange) throws Exception {
-                exchange.getIn().setBody("Hello World!");
-            }
-            
-        });
-        assertTrue(exchange.isFailed());
-        HttpOperationFailedException exception = exchange.getException(HttpOperationFailedException.class);
-        assertNotNull(exception);
-        assertEquals("This is a fault", exception.getResponseBody());
-        assertEquals(500, exception.getStatusCode());
-    }
-
-    @Override
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
-            @Override
-            public void configure() throws Exception {
-                from("jetty://http://localhost:{{port}}/test")
-                    .process(new Processor() {
-                        public void process(Exchange exchange) throws Exception {
-                            exchange.getOut().setFault(true);
-                            exchange.getOut().setBody("This is a fault");
-                        }
-                    });
-            }
-        };
-    }
-}

http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRoundtripHeaderTest.java
----------------------------------------------------------------------
diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRoundtripHeaderTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRoundtripHeaderTest.java
deleted file mode 100644
index 16a9201..0000000
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRoundtripHeaderTest.java
+++ /dev/null
@@ -1,126 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jetty;
-
-import java.io.BufferedReader;
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.InputStreamReader;
-import java.util.List;
-import java.util.Map;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.Message;
-import org.apache.camel.Processor;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.mock.MockEndpoint;
-import org.apache.camel.impl.DefaultHeaderFilterStrategy;
-import org.apache.camel.util.IOHelper;
-
-import org.junit.Test;
-
-public class HttpRoundtripHeaderTest extends BaseJettyTest {
-    protected final String uri = "http://localhost:" + getPort() + "/WhichWillGetCloseException";
-    protected final String jettyUri = "jetty:" + uri;
-    protected final String outputText = ":output";
-    protected String inputText = "input";
-    protected String expectedText = inputText + outputText;
-
-    // http://issues.apache.org/activemq/browse/CAMEL-324
-    @Test
-    public void testHttpRoundTripHeaders() throws Exception {
-        MockEndpoint mockEndpoint = resolveMandatoryEndpoint("mock:results", MockEndpoint.class);
-        mockEndpoint.expectedMessageCount(1);
-
-        InputStream answer = (InputStream) template.requestBody(uri, inputText);
-
-        verifyMockGotExpectedText(mockEndpoint, expectedText);
-
-        // read the response data
-        String lastLine = readLastLine(answer);
-
-        assertNotNull("last response line", lastLine);
-        assertEquals("response matches: " + expectedText, expectedText, lastLine);
-    }
-
-    @Test
-    public void testHttpRoundTripHeadersWithNoIgnoredHeaders() throws Exception {
-        MockEndpoint mockEndpoint = resolveMandatoryEndpoint("mock:results", MockEndpoint.class);
-        mockEndpoint.expectedMessageCount(1);
-
-        JettyHttpEndpoint endpoint = context.getEndpoint(jettyUri, JettyHttpEndpoint.class);
-        // override the default set of ignored headers which includes Content-Length
-        ((DefaultHeaderFilterStrategy)endpoint.getHeaderFilterStrategy()).setOutFilter(null);
-
-        // read the response data
-        InputStream answer = (InputStream) template.requestBody(uri, inputText);
-        verifyMockGotExpectedText(mockEndpoint, expectedText);
-
-        String lastLine = readLastLine(answer);
-        assertNotNull("last response line", lastLine);
-        
-        // Content-Length from request will truncate the output to just the inputText
-        assertEquals("response matches: " + inputText, inputText, lastLine);
-    }
-
-    @Override
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
-            public void configure() {
-                Processor processor = new Processor() {
-                    public void process(Exchange exchange) {
-                        String input = (String) exchange.getIn().getBody();
-                        // append some text to invalidate Context-Length
-                        // for the http reply
-                        exchange.getIn().setBody(input + outputText);
-                    }
-                };
-
-                // the unmarshaller does a copy from in message to out
-                // including all headers
-                from(jettyUri).unmarshal().string().process(processor).to("mock:results");
-            }
-        };
-    }
-
-    private void verifyMockGotExpectedText(MockEndpoint mockEndpoint, String expected) throws InterruptedException {
-        mockEndpoint.assertIsSatisfied();
-        List<Exchange> list = mockEndpoint.getReceivedExchanges();
-        Exchange exchange = list.get(0);
-        assertNotNull("exchange", exchange);
-        Message in = exchange.getIn();
-        assertNotNull("in", in);
-        Map<String, Object> headers = in.getHeaders();
-        assertTrue("no headers are propagated", !headers.isEmpty());
-        assertEquals("body has expectedText:" + expected, expected, in.getBody());
-    }
-
-    private String readLastLine(InputStream answer) throws IOException {
-        String lastLine = null;
-        BufferedReader reader = IOHelper.buffered(new InputStreamReader(answer));
-        while (true) {
-            String line = reader.readLine();
-            if (line == null) {
-                break;
-            }
-            lastLine = line;
-            log.info("Read: " + line);
-        }
-        reader.close();
-        return lastLine;
-    }
-}

http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/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
deleted file mode 100644
index adb78c7..0000000
--- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/HttpRouteTest.java
+++ /dev/null
@@ -1,269 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.jetty;
-
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.net.URL;
-import java.util.List;
-import java.util.Map;
-import javax.servlet.http.HttpSession;
-
-import org.apache.camel.Exchange;
-import org.apache.camel.Message;
-import org.apache.camel.Processor;
-import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.http.HttpMessage;
-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;
-import org.junit.Test;
-
-/**
- * @version 
- */
-public class HttpRouteTest extends BaseJettyTest {
-    protected static final String POST_MESSAGE = "<?xml version=\"1.0\" encoding=\"UTF-8\"?> "
-        + "<test>Hello World</test>";
-    protected String expectedBody = "<hello>world!</hello>";
-
-    private int port1;
-    private int port2;
-    private int port3;
-    private int port4;
-
-    @Test
-    public void testEndpoint() throws Exception {
-        MockEndpoint mockEndpoint = getMockEndpoint("mock:a");
-        mockEndpoint.expectedBodiesReceived(expectedBody);
-
-        invokeHttpEndpoint();
-
-        mockEndpoint.assertIsSatisfied();
-        List<Exchange> list = mockEndpoint.getReceivedExchanges();
-        Exchange exchange = list.get(0);
-        assertNotNull("exchange", exchange);
-
-        Message in = exchange.getIn();
-        assertNotNull("in", in);
-
-        Map<String, Object> headers = in.getHeaders();
-
-        log.info("Headers: " + headers);
-
-        assertTrue("Should be more than one header but was: " + headers, headers.size() > 0);
-    }
-
-    @Test
-    public void testHelloEndpoint() throws Exception {
-        ByteArrayOutputStream os = new ByteArrayOutputStream();
-        InputStream is = new URL("http://localhost:" + port2 + "/hello").openStream();
-        int c;
-        while ((c = is.read()) >= 0) {
-            os.write(c);
-        }
-
-        String data = new String(os.toByteArray());
-        assertEquals("<b>Hello World</b>", data);
-    }
-
-    @Test
-    public void testEchoEndpoint() throws Exception {
-        String out = template.requestBody("http://localhost:" + port1 + "/echo", "HelloWorld", String.class);
-        assertEquals("Get a wrong output " , "HelloWorld", out);
-    }
-
-    @Test
-    public void testPostParameter() throws Exception {
-        NameValuePair[] data = {new NameValuePair("request", "PostParameter"),
-                                new NameValuePair("others", "bloggs")};
-        HttpClient client = new HttpClient();
-        PostMethod post = new PostMethod("http://localhost:" + port1 + "/parameter");
-        post.setRequestBody(data);
-        client.executeMethod(post);
-        InputStream response = post.getResponseBodyAsStream();
-        String out = context.getTypeConverter().convertTo(String.class, response);
-        assertEquals("Get a wrong output " , "PostParameter", out);
-    }
-
-    @Test
-    public void testPostXMLMessage() throws Exception {
-        HttpClient client = new HttpClient();
-        PostMethod post = new PostMethod("http://localhost:" + port1 + "/postxml");
-        StringRequestEntity entity = new StringRequestEntity(POST_MESSAGE, "application/xml", "UTF-8");
-        post.setRequestEntity(entity);
-        client.executeMethod(post);
-        InputStream response = post.getResponseBodyAsStream();
-        String out = context.getTypeConverter().convertTo(String.class, response);
-        assertEquals("Get a wrong output " , "OK", out);
-    }
-
-    @Test
-    public void testPostParameterInURI() throws Exception {
-        HttpClient client = new HttpClient();
-        PostMethod post = new PostMethod("http://localhost:" + port1 + "/parameter?request=PostParameter&others=bloggs");
-        StringRequestEntity entity = new StringRequestEntity(POST_MESSAGE, "application/xml", "UTF-8");
-        post.setRequestEntity(entity);
-        client.executeMethod(post);
-        InputStream response = post.getResponseBodyAsStream();
-        String out = context.getTypeConverter().convertTo(String.class, response);
-        assertEquals("Get a wrong output " , "PostParameter", out);
-    }
-
-    @Test
-    public void testPutParameterInURI() throws Exception {
-        HttpClient client = new HttpClient();
-        PutMethod put = new PutMethod("http://localhost:" + port1 + "/parameter?request=PutParameter&others=bloggs");
-        StringRequestEntity entity = new StringRequestEntity(POST_MESSAGE, "application/xml", "UTF-8");
-        put.setRequestEntity(entity);
-        client.executeMethod(put);
-        InputStream response = put.getResponseBodyAsStream();
-        String out = context.getTypeConverter().convertTo(String.class, response);
-        assertEquals("Get a wrong output " , "PutParameter", out);
-    }
-    
-    @Test
-    public void testDisableStreamCache() throws Exception {
-        String response = 
-            template.requestBodyAndHeader("http://localhost:" + port3 + "/noStreamCache",
-                                          new ByteArrayInputStream("This is a test".getBytes()), "Content-Type", "application/xml", String.class);
-        
-        assertEquals("Get a wrong output ", "OK", response);
-    }
-    
-    @Test
-    public void testRequestBufferSize() throws Exception {
-        InputStream in = this.getClass().getResourceAsStream("/META-INF/LICENSE.txt");
-        int fileSize = in.available();
-        String response = 
-            template.requestBodyAndHeader("http://localhost:" + port4 + "/requestBufferSize",
-                                          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 {
-        template.requestBodyAndHeader("http://localhost:" + port1 + "/test", expectedBody, "Content-Type", "application/xml");
-    }
-
-    @Override
-    protected RouteBuilder createRouteBuilder() throws Exception {
-        return new RouteBuilder() {
-            public void configure() {
-                port1 = getPort();
-                port2 = getNextPort();
-                port3 = getNextPort();
-                port4 = getNextPort();
-
-
-                // enable stream cache
-                context.setStreamCaching(true);
-
-                from("jetty:http://localhost:" + port1 + "/test").to("mock:a");
-
-                Processor proc = new Processor() {
-                    public void process(Exchange exchange) throws Exception {
-                        try {
-                            HttpMessage message = (HttpMessage)exchange.getIn();
-                            HttpSession session = message.getRequest().getSession();
-                            assertNotNull("we should get session here", session);
-                        } catch (Exception e) {
-                            exchange.getOut().setFault(true);
-                            exchange.getOut().setBody(e);
-                        }
-                        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 {
-                        Message out = exchange.getOut();
-                        out.copyFrom(exchange.getIn());
-                        log.info("The body's object is " + exchange.getIn().getBody());
-                        log.info("Process body = " + exchange.getIn().getBody(String.class));
-                        InputStreamCache cache = out.getBody(InputStreamCache.class);
-                        cache.reset();
-                    }
-                };
-                from("jetty:http://localhost:" + port2 + "/hello?sessionSupport=true").process(proc);
-
-                from("jetty:http://localhost:" + port1 + "/echo").process(printProcessor).process(printProcessor);
-
-                Processor procParameters = new Processor() {
-                    public void process(Exchange exchange) throws Exception {
-                        // As the request input stream is cached by DefaultHttpBinding,
-                        // HttpServletRequest can't get the parameters of post message
-                        String value = exchange.getIn().getHeader("request", String.class);
-                        if (value != null) {
-                            assertNotNull("The value of the parameter should not be null", value);
-                            exchange.getOut().setBody(value);
-                        } else {
-                            exchange.getOut().setBody("Can't get a right parameter");
-                        }
-                    }
-                };
-
-                from("jetty:http://localhost:" + port1 + "/parameter").process(procParameters);
-
-                from("jetty:http://localhost:" + port1 + "/postxml").process(new Processor() {
-                    public void process(Exchange exchange) throws Exception {
-                        String value = exchange.getIn().getBody(String.class);
-                        assertEquals("The response message is wrong", value, POST_MESSAGE);
-                        exchange.getOut().setBody("OK");
-                    }
-                });
-                
-                from("jetty:http://localhost:" + port3 + "/noStreamCache?disableStreamCache=true").noStreamCaching().process(new Processor() {
-                    public void process(Exchange exchange) throws Exception {
-                        InputStream is = (InputStream)exchange.getIn().getBody();                        
-                        assertTrue("It should be a raw inputstream", is instanceof org.eclipse.jetty.server.HttpInput);
-                        String request = exchange.getIn().getBody(String.class);
-                        assertEquals("Got a wrong request", "This is a test", request);
-                        exchange.getOut().setBody("OK");
-                    }
-                });
-                
-                from("jetty:http://localhost:" + port4 + "/requestBufferSize").process(new Processor() {
-                    public void process(Exchange exchange) throws Exception {
-                        String string = exchange.getIn().getBody(String.class);
-                        exchange.getOut().setBody(string);
-                    }
-                });
-            }
-        };
-    }
-}
-
-


Mime
View raw message