http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyContinuationDisabledTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyContinuationDisabledTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyContinuationDisabledTest.java deleted file mode 100644 index 135241f..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyContinuationDisabledTest.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.builder.RouteBuilder; -import org.junit.Test; - -/** - * @version - */ -public class JettyContinuationDisabledTest extends BaseJettyTest { - - @Test - public void testJettyContinuationDisabled() throws Exception { - getMockEndpoint("mock:result").expectedBodiesReceived("Bye World"); - - String out = template.requestBody("http://localhost:{{port}}/myservice";, null, String.class); - assertEquals("Bye World", out); - - assertMockEndpointsSatisfied(); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - // disable continuation - JettyHttpComponent jetty = context.getComponent("jetty", JettyHttpComponent.class); - jetty.setUseContinuation(false); - - from("jetty:http://localhost:{{port}}/myservice";) - .process(new Processor() { - public void process(Exchange exchange) throws Exception { - Thread.sleep(1000); - exchange.getOut().setBody("Bye World"); - } - }) - .to("mock:result"); - } - }; - } -}
http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyEnableJmxTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyEnableJmxTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyEnableJmxTest.java deleted file mode 100644 index d5b0adb..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyEnableJmxTest.java +++ /dev/null @@ -1,157 +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.lang.management.ManagementFactory; -import java.util.List; -import java.util.Set; -import javax.management.MBeanServer; -import javax.management.MBeanServerConnection; -import javax.management.MBeanServerFactory; -import javax.management.ObjectName; - -import org.apache.camel.builder.RouteBuilder; -import org.apache.camel.component.mock.MockEndpoint; -import org.junit.Test; - -public class JettyEnableJmxTest extends BaseJettyTest { - - private String serverUri0; - private String serverUri1; - private String serverUri2; - private String serverUri3; - private MBeanServerConnection mbsc; - - @Override - public void tearDown() throws Exception { - releaseMBeanServers(); - mbsc = null; - super.tearDown(); - disableJMX(); - } - - @Override - public void setUp() throws Exception { - enableJMX(); - releaseMBeanServers(); - super.setUp(); - mbsc = getMBeanConnection(); - } - - @Test - public void testEnableJmxProperty() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:result"); - String expectedBody = "<html><body>foo</body></html>"; - mock.expectedBodiesReceived(expectedBody, expectedBody, expectedBody, expectedBody); - mock.expectedHeaderReceived("x", "foo"); - - template.requestBody(serverUri0 + "&x=foo", null, Object.class); - template.requestBody(serverUri1 + "&x=foo", null, Object.class); - template.requestBody(serverUri2 + "&x=foo", null, Object.class); - template.requestBody(serverUri3 + "&x=foo", null, Object.class); - - assertMockEndpointsSatisfied(); - - Set<ObjectName> s = mbsc.queryNames(new ObjectName("org.eclipse.jetty.server:type=server,*"), null); - assertEquals("Could not find 2 Jetty Server: " + s, 2, s.size()); - } - - @Test - public void testShutdown() throws Exception { - Set<ObjectName> s = mbsc.queryNames(new ObjectName("org.eclipse.jetty.server:type=server,*"), null); - assertEquals("Could not find 2 Jetty Server: " + s, 2, s.size()); - - context.stop(); - - s = mbsc.queryNames(new ObjectName("org.eclipse.jetty.server:type=server,*"), null); - assertEquals("Could not find 0 Jetty Server: " + s, 0, s.size()); - } - - @Test - public void testEndpointDisconnect() throws Exception { - Set<ObjectName> s = mbsc.queryNames(new ObjectName("org.eclipse.jetty.server:type=server,*"), null); - assertEquals("Could not find 2 Jetty Server: " + s, 2, s.size()); - - context.stopRoute("route0"); - - s = mbsc.queryNames(new ObjectName("org.eclipse.jetty.server:type=server,*"), null); - assertEquals("Could not find 1 Jetty Server: " + s, 1, s.size()); - - context.stopRoute("route2"); - context.stopRoute("route3"); - - s = mbsc.queryNames(new ObjectName("org.eclipse.jetty.server:type=server,*"), null); - assertEquals("Could not find 1 Jetty Server: " + s, 1, s.size()); - - context.stopRoute("route1"); - - s = mbsc.queryNames(new ObjectName("org.eclipse.jetty.server:type=server,*"), null); - assertEquals("Could not find 0 Jetty Server: " + s, 0, s.size()); - } - - @Override - protected boolean useJmx() { - return true; - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - public void configure() throws Exception { - serverUri0 = "http://localhost:"; + getNextPort() + "/myservice?enableJmx=true"; - serverUri1 = "http://localhost:"; + getNextPort() + "/myservice?enableJmx=true"; - serverUri2 = "http://localhost:"; + getNextPort() + "/myservice?enableJmx=false"; - serverUri3 = "http://localhost:"; + getNextPort() + "/myservice?enableJmx=false"; - - from("jetty:" + serverUri0) - .routeId("route0") - .setBody().simple("<html><body>${in.header.x}</body></html>") - .to("mock:result"); - - from("jetty:" + serverUri1) - .routeId("route1") - .setBody().simple("<html><body>${in.header.x}</body></html>") - .to("mock:result"); - - from("jetty:" + serverUri2) - .routeId("route2") - .setBody().simple("<html><body>${in.header.x}</body></html>") - .to("mock:result"); - - from("jetty:" + serverUri3) - .routeId("route3") - .setBody().simple("<html><body>${in.header.x}</body></html>") - .to("mock:result"); - } - }; - } - - protected void releaseMBeanServers() { - List<MBeanServer> servers = MBeanServerFactory.findMBeanServer(null); - - for (MBeanServer server : servers) { - MBeanServerFactory.releaseMBeanServer(server); - } - } - - protected MBeanServerConnection getMBeanConnection() throws Exception { - if (mbsc == null) { - mbsc = ManagementFactory.getPlatformMBeanServer(); - } - return mbsc; - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyEndpointContinuationDisabledTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyEndpointContinuationDisabledTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyEndpointContinuationDisabledTest.java deleted file mode 100644 index 933d1c8..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyEndpointContinuationDisabledTest.java +++ /dev/null @@ -1,55 +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 JettyEndpointContinuationDisabledTest extends BaseJettyTest { - - @Test - public void testJettyContinuationDisabled() throws Exception { - getMockEndpoint("mock:result").expectedBodiesReceived("Bye World"); - - String out = template.requestBody("http://localhost:{{port}}/myservice";, null, String.class); - assertEquals("Bye World", out); - - assertMockEndpointsSatisfied(); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - from("jetty:http://localhost:{{port}}/myservice?useContinuation=false";) - .process(new Processor() { - public void process(Exchange exchange) throws Exception { - Thread.sleep(1000); - exchange.getOut().setBody("Bye World"); - } - }) - .to("mock:result"); - } - }; - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyEndpointSetHttpTraceTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyEndpointSetHttpTraceTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyEndpointSetHttpTraceTest.java deleted file mode 100644 index 111d268..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyEndpointSetHttpTraceTest.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.builder.RouteBuilder; -import org.apache.commons.httpclient.HttpClient; -import org.apache.commons.httpclient.methods.TraceMethod; -import org.junit.Test; - -public class JettyEndpointSetHttpTraceTest extends BaseJettyTest { - - private int portTraceOn = getNextPort(); - private int portTraceOff = getNextPort(); - - @Test - public void testTraceDisabled() throws Exception { - HttpClient httpclient = new HttpClient(); - TraceMethod trace = new TraceMethod("http://localhost:"; + portTraceOff + "/myservice"); - httpclient.executeMethod(trace); - - // TRACE shouldn't be allowed by default - assertTrue(trace.getStatusCode() == 405); - trace.releaseConnection(); - } - - @Test - public void testTraceEnabled() throws Exception { - HttpClient httpclient = new HttpClient(); - TraceMethod trace = new TraceMethod("http://localhost:"; + portTraceOn + "/myservice"); - httpclient.executeMethod(trace); - - // TRACE is now allowed - assertTrue(trace.getStatusCode() == 200); - trace.releaseConnection(); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - from("jetty:http://localhost:"; + portTraceOff + "/myservice").to("log:foo"); - from("jetty:http://localhost:"; + portTraceOn + "/myservice?traceEnabled=true").to("log:bar"); - } - }; - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHandle404Test.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHandle404Test.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHandle404Test.java deleted file mode 100644 index 12282de..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHandle404Test.java +++ /dev/null @@ -1,107 +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.Component; -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.apache.camel.component.mock.MockEndpoint; -import org.apache.camel.processor.aggregate.AggregationStrategy; -import org.junit.Test; - -/** - * Based on end user on forum how to get the 404 error code in his enrich aggregator - * - * @version - */ -public class JettyHandle404Test extends BaseJettyTest { - - public String getProducerUrl() { - return "http://localhost:{{port}}/myserver?user=Camel";; - } - - @Test - public void testSimulate404() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:result"); - mock.expectedBodiesReceived("Page not found"); - mock.expectedHeaderReceived(Exchange.HTTP_RESPONSE_CODE, 404); - - template.sendBody("direct:start", "Hello World"); - - assertMockEndpointsSatisfied(); - } - - @Test - public void testCustomerErrorHandler() throws Exception { - String response = template.requestBody("http://localhost:{{port}}/myserver1?throwExceptionOnFailure=false";, null, String.class); - // look for the error message which is sent by MyErrorHandler - assertTrue("Get a wrong error message", response.indexOf("MyErrorHandler") > 0); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - // setup the jetty component with the customx error handler - JettyHttpComponent jettyComponent = (JettyHttpComponent)context.getComponent("jetty"); - jettyComponent.setErrorHandler(new MyErrorHandler()); - - // disable error handling - errorHandler(noErrorHandler()); - - from("direct:start").enrich("direct:tohttp", new AggregationStrategy() { - public Exchange aggregate(Exchange original, Exchange resource) { - // get the response code - Integer code = resource.getIn().getHeader(Exchange.HTTP_RESPONSE_CODE, Integer.class); - assertEquals(404, code.intValue()); - return resource; - } - }).to("mock:result"); - - // use this sub route as indirection to handle the HttpOperationFailedException - // and set the data back as data on the exchange to not cause the exception to be thrown - from("direct:tohttp") - .doTry() - .to(getProducerUrl()) - .doCatch(HttpOperationFailedException.class) - .process(new Processor() { - public void process(Exchange exchange) { - // copy the caused exception values to the exchange as we want the response in the regular exchange - // instead as an exception that will get thrown and thus the route breaks - HttpOperationFailedException cause = exchange.getProperty(Exchange.EXCEPTION_CAUGHT, HttpOperationFailedException.class); - exchange.getOut().setHeader(Exchange.HTTP_RESPONSE_CODE, cause.getStatusCode()); - exchange.getOut().setBody(cause.getResponseBody()); - } - }) - .end(); - - - // this is our jetty server where we simulate the 404 - from("jetty://http://localhost:{{port}}/myserver";) - .process(new Processor() { - public void process(Exchange exchange) throws Exception { - exchange.getOut().setBody("Page not found"); - exchange.getOut().setHeader(Exchange.HTTP_RESPONSE_CODE, 404); - } - }); - } - }; - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpBindingRefTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpBindingRefTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpBindingRefTest.java deleted file mode 100644 index 54e6989..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpBindingRefTest.java +++ /dev/null @@ -1,101 +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.IOException; - -import org.apache.camel.CamelExecutionException; -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.HttpOperationFailedException; -import org.apache.camel.impl.JndiRegistry; -import org.apache.camel.spi.HeaderFilterStrategy; -import org.junit.Test; - -/** - * Unit test for jetty http binding ref option. - */ -public class JettyHttpBindingRefTest extends BaseJettyTest { - - @Test - public void testDefaultJettyHttpBinding() throws Exception { - Object out = template.requestBody("jetty:http://localhost:{{port}}/myapp/myservice?jettyHttpBindingRef=default";, "Hello World"); - assertEquals("Bye World", context.getTypeConverter().convertTo(String.class, out)); - - try { - template.requestBody("jetty:http://localhost:{{port}}/myapp/myotherservice";, "Hello World"); - fail(); - } catch (CamelExecutionException e) { - assertNotNull(e.getCause()); - assertTrue(e.getCause() instanceof HttpOperationFailedException); - - assertFalse("Not exactly the message the server returned.".equals(((HttpOperationFailedException) e.getCause()).getResponseBody())); - } - } - - @Test - public void testCustomJettyHttpBinding() throws Exception { - - Object out = template.requestBody("jetty:http://localhost:{{port}}/myapp/myotherservice?jettyHttpBindingRef=myownbinder";, "Hello World"); - assertEquals("Not exactly the message the server returned.", context.getTypeConverter().convertTo(String.class, out)); - } - - @Override - protected JndiRegistry createRegistry() throws Exception { - JndiRegistry jndi = super.createRegistry(); - jndi.bind("default", new DefaultJettyHttpBinding()); - jndi.bind("myownbinder", new MyJettyHttpBinding()); - return jndi; - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - errorHandler(noErrorHandler()); - - from("jetty:http://localhost:{{port}}/myapp/myservice";).transform().constant("Bye World"); - - from("jetty:http://localhost:{{port}}/myapp/myotherservice";).process(new Processor() { - public void process(Exchange exchange) throws Exception { - throw new IllegalStateException("Not implemented"); - } - }); - } - }; - } - - // START SNIPPET: e1 - public class MyJettyHttpBinding extends DefaultJettyHttpBinding { - @Override - protected void populateResponse(Exchange exchange, JettyContentExchange httpExchange, Message in, - HeaderFilterStrategy strategy, int responseCode) throws IOException { - - Message answer = exchange.getOut(); - - answer.setHeaders(in.getHeaders()); - answer.setHeader(Exchange.HTTP_RESPONSE_CODE, responseCode); - answer.setBody("Not exactly the message the server returned."); - } - } - // END SNIPPET: e1 - -} - http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpBridgeEncodedPathTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpBridgeEncodedPathTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpBridgeEncodedPathTest.java deleted file mode 100644 index a09afc4..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpBridgeEncodedPathTest.java +++ /dev/null @@ -1,66 +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; - -public class JettyHttpBridgeEncodedPathTest extends BaseJettyTest { - - private int port1; - private int port2; - - @Test - public void testJettyHttpClient() throws Exception { - String response = template.requestBody("http://localhost:"; + port2 + "/jettyTestRouteA?param1=%2B447777111222", null, String.class); - assertEquals("Get a wrong response", "param1=+447777111222", response); - } - - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - public void configure() { - - port1 = getPort(); - port2 = getNextPort(); - - errorHandler(noErrorHandler()); - - Processor serviceProc = new Processor() { - public void process(Exchange exchange) throws Exception { - // %2B becomes decoded to a space - Object s = exchange.getIn().getHeader("param1"); - // can be either + or %2B - assertTrue(s.equals(" 447777111222") || s.equals("+447777111222") || s.equals("%2B447777111222")); - - // send back the query - exchange.getOut().setBody(exchange.getIn().getHeader(Exchange.HTTP_QUERY)); - } - }; - from("jetty://http://localhost:"; + port2 + "/jettyTestRouteA?matchOnUriPrefix=true") - .log("Using JettyTestRouteA route: CamelHttpPath=[${header.CamelHttpPath}], CamelHttpUri=[${header.CamelHttpUri}]") - .to("jetty://http://localhost:"; + port1 + "/jettyTestRouteB?throwExceptionOnFailure=false&bridgeEndpoint=true"); - - from("jetty://http://localhost:"; + port1 + "/jettyTestRouteB?matchOnUriPrefix=true") - .log("Using JettyTestRouteB route: CamelHttpPath=[${header.CamelHttpPath}], CamelHttpUri=[${header.CamelHttpUri}]") - .process(serviceProc); - } - }; - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpClientOptionsTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpClientOptionsTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpClientOptionsTest.java deleted file mode 100644 index 387cdeb..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpClientOptionsTest.java +++ /dev/null @@ -1,77 +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.http.HttpEndpoint; -import org.apache.camel.component.http.HttpProducer; -import org.eclipse.jetty.client.HttpClient; -import org.junit.Test; - -/** - * Unit test for http client options. - */ -public class JettyHttpClientOptionsTest extends BaseJettyTest { - - @Test - public void testCustomHttpBinding() throws Exception { - // assert jetty was configured with our timeout - HttpEndpoint jettyEndpoint = context.getEndpoint("http://localhost:{{port}}/myapp/myservice?httpClient.soTimeout=5555";, HttpEndpoint.class); - assertNotNull("Jetty endpoint should not be null ", jettyEndpoint); - HttpProducer producer = (HttpProducer)jettyEndpoint.createProducer(); - assertEquals("Get the wrong http client parameter", 5555, producer.getHttpClient().getParams().getSoTimeout()); - - // send and receive - Object out = template.requestBody("http://localhost:{{port}}/myapp/myservice";, "Hello World"); - assertEquals("Bye World", context.getTypeConverter().convertTo(String.class, out)); - } - - @Test - public void testProxySettingOfJettyHttpClient() throws Exception { - // setup the Proxy setting through the URI - HttpEndpoint jettyEndpoint = context.getEndpoint("jetty://http://localhost:{{port}}/proxy/setting?proxyHost=192.168.0.1&proxyPort=9090";, HttpEndpoint.class); - assertNotNull("Jetty endpoint should not be null ", jettyEndpoint); - JettyHttpProducer producer = (JettyHttpProducer)jettyEndpoint.createProducer(); - assertProxyAddress(producer.getClient(), "192.168.0.1", 9090); - - // setup the context properties - context.getProperties().put("http.proxyHost", "192.168.0.2"); - context.getProperties().put("http.proxyPort", "8080"); - jettyEndpoint = context.getEndpoint("jetty://http://localhost:{{port}}/proxy2/setting";, HttpEndpoint.class); - producer = (JettyHttpProducer)jettyEndpoint.createProducer(); - assertProxyAddress(producer.getClient(), "192.168.0.2", 8080); - context.getProperties().clear(); - - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - from("jetty:http://localhost:{{port}}/myapp/myservice?httpClient.soTimeout=5555";).transform().constant("Bye World"); - } - }; - } - - private void assertProxyAddress(HttpClient client, String expectedHost, int expectedPort) { - CamelHttpClient camelHttpClient = (CamelHttpClient)client; - assertEquals("Got the wrong http proxy host parameter", expectedHost, camelHttpClient.getProxyHost()); - assertEquals("Got the wrong http proxy port paramerter", expectedPort, camelHttpClient.getProxyPort()); - } - -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpComponentConfigurationAndDocumentationTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpComponentConfigurationAndDocumentationTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpComponentConfigurationAndDocumentationTest.java deleted file mode 100644 index eae83bf..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpComponentConfigurationAndDocumentationTest.java +++ /dev/null @@ -1,58 +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.CamelContext; -import org.apache.camel.ComponentConfiguration; -import org.apache.camel.EndpointConfiguration; -import org.apache.camel.impl.DefaultCamelContext; -import org.apache.camel.test.junit4.CamelTestSupport; -import org.junit.Ignore; -import org.junit.Test; - -public class JettyHttpComponentConfigurationAndDocumentationTest extends CamelTestSupport { - - @Override - public boolean isUseRouteBuilder() { - return false; - } - - @Test - public void testComponentConfiguration() throws Exception { - JettyHttpComponent comp = context.getComponent("jetty", JettyHttpComponent.class); - EndpointConfiguration conf = comp.createConfiguration("jetty://http://localhost:8080/myapp?"; - + "httpClientMinThreads=4&httpClientMaxThreads=8"); - - assertEquals("4", conf.getParameter("httpClientMinThreads")); - assertEquals("8", conf.getParameter("httpClientMaxThreads")); - - ComponentConfiguration compConf = comp.createComponentConfiguration(); - String json = compConf.createParameterJsonSchema(); - assertNotNull(json); - assertTrue(json.contains("\"httpClientMaxThreads\": { \"type\": \"integer\"")); - assertTrue(json.contains("\"sessionSupport\": { \"type\": \"boolean\", \"javaType\": \"boolean\" },")); - } - - @Test - @Ignore // TODO Need to investigate why this fails while html is present - public void testComponentDocumentation() throws Exception { - CamelContext context = new DefaultCamelContext(); - String html = context.getComponentDocumentation("jetty"); - assertNotNull("Should have found some auto-generated HTML", html); - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpContentTypeTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpContentTypeTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpContentTypeTest.java deleted file mode 100644 index 1edc74b..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpContentTypeTest.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 java.nio.charset.Charset; - -import org.apache.camel.Exchange; -import org.apache.camel.Message; -import org.apache.camel.builder.RouteBuilder; -import org.junit.Test; - -public class JettyHttpContentTypeTest extends BaseJettyTest { - - private static final String CHARSET = "ISO-8859-1"; - - @Test - public void testContentType() throws Exception { - getMockEndpoint("mock:input").expectedBodiesReceived("Hello World"); - getMockEndpoint("mock:input").expectedHeaderReceived(Exchange.CONTENT_TYPE, - "text/plain; charset=\"" + CHARSET + "\""); - getMockEndpoint("mock:input").expectedHeaderReceived(Exchange.HTTP_CHARACTER_ENCODING, CHARSET); - getMockEndpoint("mock:input").expectedHeaderReceived(Exchange.HTTP_URL, - "http://0.0.0.0:"; + getPort() + "/foo"); - getMockEndpoint("mock:input").expectedPropertyReceived(Exchange.CHARSET_NAME, CHARSET); - - byte[] data = "Hello World".getBytes(Charset.forName(CHARSET)); - String out = template.requestBodyAndHeader("jetty:http://0.0.0.0:{{port}}/foo";, data, - "content-type", "text/plain; charset=\"" + CHARSET + "\"", String.class); - assertEquals("Bye World", out); - - Exchange exchange = getMockEndpoint("mock:input").getExchanges().get(0); - Message in = exchange.getIn(); - System.out.println(in.getHeaders()); - assertMockEndpointsSatisfied(); - } - - @Test - public void testContentTypeWithAction() throws Exception { - getMockEndpoint("mock:input").expectedBodiesReceived("Hello World"); - getMockEndpoint("mock:input").expectedHeaderReceived(Exchange.CONTENT_TYPE, - "text/plain;charset=\"" + CHARSET + "\";action=\"http://somewhere.com/foo\"";); - getMockEndpoint("mock:input").expectedHeaderReceived(Exchange.HTTP_CHARACTER_ENCODING, CHARSET); - getMockEndpoint("mock:input").expectedHeaderReceived(Exchange.HTTP_URL, "http://0.0.0.0:"; + getPort() + "/foo"); - getMockEndpoint("mock:input").expectedPropertyReceived(Exchange.CHARSET_NAME, CHARSET); - - byte[] data = "Hello World".getBytes(Charset.forName(CHARSET)); - String out = template.requestBodyAndHeader("jetty:http://0.0.0.0:{{port}}/foo";, data, - "content-type", "text/plain;charset=\"" + CHARSET + "\";action=\"http://somewhere.com/foo\"";, String.class); - assertEquals("Bye World", out); - - assertMockEndpointsSatisfied(); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - from("jetty:http://0.0.0.0:{{port}}/foo";) - .to("mock:input") - .transform().constant("Bye World"); - } - }; - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpEndpointDisconnectTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpEndpointDisconnectTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpEndpointDisconnectTest.java deleted file mode 100644 index 373681c..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpEndpointDisconnectTest.java +++ /dev/null @@ -1,42 +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; - -/** - * Unit test to verify that the Jetty HTTP connector is correctly disconnected on shutdown - */ -public class JettyHttpEndpointDisconnectTest extends BaseJettyTest { - - private String serverUri = "http://localhost:"; + getPort() + "/myservice"; - - @Test - public void testContextShutdownRemovesHttpConnector() throws Exception { - context.stop(); - assertEquals("Connector should have been removed", 0, JettyHttpComponent.CONNECTORS.size()); - } - - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - public void configure() throws Exception { - from("jetty:" + serverUri).to("mock:result"); - } - }; - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpGetWithParamAsExchangeHeaderTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpGetWithParamAsExchangeHeaderTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpGetWithParamAsExchangeHeaderTest.java deleted file mode 100644 index acca07d..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpGetWithParamAsExchangeHeaderTest.java +++ /dev/null @@ -1,128 +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.builder.RouteBuilder; -import org.apache.camel.component.mock.MockEndpoint; -import org.junit.Ignore; -import org.junit.Test; - -/** - * Unit test to verify that we can have URI options for external system (endpoint is lenient) - */ -public class JettyHttpGetWithParamAsExchangeHeaderTest extends BaseJettyTest { - - private String serverUri = "http://localhost:"; + getPort() + "/myservice"; - - @Test - public void testHttpGetWithParamsViaURI() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:result"); - mock.expectedMessageCount(1); - mock.expectedHeaderReceived("one", "einz"); - mock.expectedHeaderReceived("two", "twei"); - mock.expectedHeaderReceived(Exchange.HTTP_METHOD, "GET"); - - template.requestBody(serverUri + "?one=einz&two=twei", null, Object.class); - - assertMockEndpointsSatisfied(); - } - - @Test - public void testHttpGetWithUTF8EncodedParamsViaURI() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:result"); - mock.expectedMessageCount(1); - mock.expectedHeaderReceived("message", "Keine g\u00FCltige GPS-Daten!"); - mock.expectedHeaderReceived(Exchange.HTTP_METHOD, "GET"); - - template.requestBody(serverUri + "?message=Keine%20g%C3%BCltige%20GPS-Daten!", null, Object.class); - - assertMockEndpointsSatisfied(); - } - - @Test - @Ignore - public void testHttpGetWithISO8859EncodedParamsViaURI() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:result"); - mock.expectedMessageCount(1); - mock.expectedHeaderReceived("message", "Keine g\u00C6ltige GPS-Daten!"); - mock.expectedHeaderReceived(Exchange.HTTP_METHOD, "GET"); - - template.requestBody(serverUri + "?message=Keine+g%C6ltige+GPS-Daten%21", null, Object.class); - - assertMockEndpointsSatisfied(); - } - - @Test - public void testHttpGetWithSpaceInParams() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:result"); - mock.expectedMessageCount(1); - mock.expectedHeaderReceived("message", " World"); - mock.expectedHeaderReceived(Exchange.HTTP_METHOD, "GET"); - - // parameter starts with a space using %2B as decimal encoded - template.requestBody(serverUri + "?message=%2BWorld", null, Object.class); - - assertMockEndpointsSatisfied(); - } - - @Test - public void testHttpGetWithSpaceAsPlusInParams() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:result"); - mock.expectedMessageCount(1); - mock.expectedHeaderReceived("message", " World"); - mock.expectedHeaderReceived(Exchange.HTTP_METHOD, "GET"); - - // parameter starts with a space using + decoded - template.requestBody(serverUri + "?message=+World", null, Object.class); - - assertMockEndpointsSatisfied(); - } - - @Test - public void testHttpGetWithParamsViaHeader() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:result"); - mock.expectedMessageCount(1); - mock.expectedHeaderReceived("one", "uno"); - mock.expectedHeaderReceived("two", "dos"); - mock.expectedHeaderReceived(Exchange.HTTP_METHOD, "GET"); - - template.requestBodyAndHeader(serverUri, null, Exchange.HTTP_QUERY, "one=uno&two=dos"); - - assertMockEndpointsSatisfied(); - } - - @Test - public void testHttpPost() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:result"); - mock.expectedMessageCount(1); - mock.expectedBodiesReceived("Hello World"); - mock.expectedHeaderReceived(Exchange.HTTP_METHOD, "POST"); - - template.requestBody(serverUri, "Hello World"); - - assertMockEndpointsSatisfied(); - } - - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - public void configure() throws Exception { - from("jetty:" + serverUri).to("mock:result"); - } - }; - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpGetWithParamTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpGetWithParamTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpGetWithParamTest.java deleted file mode 100644 index c2aeecb..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpGetWithParamTest.java +++ /dev/null @@ -1,93 +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.HttpMessage; -import org.apache.camel.component.mock.MockEndpoint; -import org.junit.Test; - -/** - * Unit test to verify that we can have URI options for external system (endpoint is lenient) - */ -public class JettyHttpGetWithParamTest extends BaseJettyTest { - - private String serverUri = "http://localhost:"; + getPort() + "/myservice"; - private MyParamsProcessor processor = new MyParamsProcessor(); - - @Test - public void testHttpGetWithParamsViaURI() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:result"); - mock.expectedBodiesReceived("Bye World"); - mock.expectedHeaderReceived("one", "eins"); - mock.expectedHeaderReceived("two", "zwei"); - - template.requestBody(serverUri + "?one=uno&two=dos", "Hello World"); - - assertMockEndpointsSatisfied(); - } - - @Test - public void testHttpGetWithParamsViaHeader() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:result"); - mock.expectedBodiesReceived("Bye World"); - mock.expectedHeaderReceived("one", "eins"); - mock.expectedHeaderReceived("two", "zwei"); - - template.requestBodyAndHeader(serverUri, "Hello World", Exchange.HTTP_QUERY, "one=uno&two=dos"); - - assertMockEndpointsSatisfied(); - } - - @Test - public void testHttpGetFromOtherRoute() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:result"); - mock.expectedBodiesReceived("Bye World"); - mock.expectedHeaderReceived("one", "eins"); - mock.expectedHeaderReceived("two", "zwei"); - - template.requestBodyAndHeader("direct:start", "Hello World", "parameters", "one=uno&two=dos"); - - assertMockEndpointsSatisfied(); - } - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - public void configure() throws Exception { - from("jetty:" + serverUri).process(processor).to("mock:result"); - from("direct:start") - .setHeader(Exchange.HTTP_METHOD, constant("GET")) - .setHeader(Exchange.HTTP_URI, simple(serverUri + "?${in.headers.parameters}")) - .to("http://example";); - } - }; - } - - private static class MyParamsProcessor implements Processor { - public void process(Exchange exchange) throws Exception { - HttpMessage message = (HttpMessage)exchange.getIn(); - assertNotNull(message.getRequest()); - assertEquals("uno", message.getRequest().getParameter("one")); - assertEquals("dos", message.getRequest().getParameter("two")); - - exchange.getOut().setBody("Bye World"); - exchange.getOut().setHeader("one", "eins"); - exchange.getOut().setHeader("two", "zwei"); - } - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpHeadersTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpHeadersTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpHeadersTest.java deleted file mode 100644 index 31b6e45..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyHttpHeadersTest.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.Exchange; -import org.apache.camel.builder.RouteBuilder; -import org.junit.Test; - -public class JettyHttpHeadersTest extends BaseJettyTest { - - @Test - public void testHttpHeaders() throws Exception { - getMockEndpoint("mock:input").expectedBodiesReceived("Hello World"); - getMockEndpoint("mock:input").expectedHeaderReceived("beer", "yes"); - getMockEndpoint("mock:input").expectedHeaderReceived(Exchange.HTTP_METHOD, "POST"); - getMockEndpoint("mock:input").expectedHeaderReceived(Exchange.HTTP_URL, "http://localhost:"; + getPort() + "/foo"); - getMockEndpoint("mock:input").expectedHeaderReceived(Exchange.HTTP_URI, "/foo"); - getMockEndpoint("mock:input").expectedHeaderReceived(Exchange.HTTP_QUERY, "beer=yes"); - getMockEndpoint("mock:input").expectedHeaderReceived(Exchange.HTTP_PATH, ""); - - String out = template.requestBody("http://localhost:{{port}}/foo?beer=yes";, "Hello World", String.class); - assertEquals("Bye World", out); - - assertMockEndpointsSatisfied(); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - from("jetty:http://0.0.0.0:{{port}}/foo";) - .to("mock:input") - .transform().constant("Bye World"); - } - }; - } - - -} http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyImageFileTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyImageFileTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyImageFileTest.java deleted file mode 100644 index ed61bda..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyImageFileTest.java +++ /dev/null @@ -1,71 +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.File; - -import org.apache.camel.Endpoint; -import org.apache.camel.Exchange; -import org.apache.camel.Processor; -import org.apache.camel.builder.RouteBuilder; -import org.apache.camel.util.MessageHelper; -import org.junit.Test; - -/** - * Unit test for exposing a http server that returns images - */ -public class JettyImageFileTest extends BaseJettyTest { - - private void sendImageContent(boolean usingGZip) throws Exception { - Endpoint endpoint = context.getEndpoint("http://localhost:{{port}}/myapp/myservice";); - Exchange exchange = endpoint.createExchange(); - if (usingGZip) { - exchange.getIn().setHeader(Exchange.CONTENT_ENCODING, "gzip"); - } - template.send(endpoint, exchange); - - assertNotNull(exchange.getOut().getBody()); - assertEquals("Get a wrong content-type ", MessageHelper.getContentType(exchange.getOut()), "image/jpeg"); - } - - @Test - public void testImageContentType() throws Exception { - sendImageContent(false); - } - - @Test - public void testImageContentWithGZip() throws Exception { - sendImageContent(true); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - public void configure() throws Exception { - from("jetty:http://localhost:{{port}}/myapp/myservice";).process(new MyImageService()); - } - }; - } - - public class MyImageService implements Processor { - public void process(Exchange exchange) throws Exception { - exchange.getOut().setBody(new File("src/test/data/logo.jpeg")); - exchange.getOut().setHeader("Content-Type", "image/jpeg"); - } - } - -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyOnExceptionHandledTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyOnExceptionHandledTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyOnExceptionHandledTest.java deleted file mode 100644 index e2fb3c7..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyOnExceptionHandledTest.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.builder.RouteBuilder; -import org.junit.Test; - -/** - * @version - */ -public class JettyOnExceptionHandledTest extends BaseJettyTest { - - @Test - public void testJettyOnException() throws Exception { - Exchange reply = template.request("http://localhost:{{port}}/myserver?throwExceptionOnFailure=false";, null); - - assertNotNull(reply); - assertEquals("Dude something went wrong", reply.getOut().getBody(String.class)); - assertEquals(500, reply.getOut().getHeader(Exchange.HTTP_RESPONSE_CODE)); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - // START SNIPPET: e1 - from("jetty://http://localhost:{{port}}/myserver";) - // use onException to catch all exceptions and return a custom reply message - .onException(Exception.class) - .handled(true) - // create a custom failure response - .transform(constant("Dude something went wrong")) - // we must remember to set error code 500 as handled(true) - // otherwise would let Camel thing its a OK response (200) - .setHeader(Exchange.HTTP_RESPONSE_CODE, constant(500)) - .end() - // now just force an exception immediately - .throwException(new IllegalArgumentException("I cannot do this")); - // END SNIPPET: e1 - } - }; - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyResponseBodyWhenErrorTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyResponseBodyWhenErrorTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyResponseBodyWhenErrorTest.java deleted file mode 100644 index 80de7d6..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyResponseBodyWhenErrorTest.java +++ /dev/null @@ -1,64 +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; - -/** - * Unit test for HttpOperationFailedException should contain response body - */ -public class JettyResponseBodyWhenErrorTest extends BaseJettyTest { - - @Test - public void testResponseBodyWhenError() throws Exception { - try { - template.requestBody("http://localhost:{{port}}/myapp/myservice";, "bookid=123"); - fail("Should have thrown an exception"); - } catch (RuntimeCamelException e) { - HttpOperationFailedException cause = assertThrowable(HttpOperationFailedException.class, e.getCause()); - assertEquals(500, cause.getStatusCode()); - String body = context.getTypeConverter().convertTo(String.class, cause.getResponseBody()); - assertTrue(body.indexOf("Damm") > -1); - assertTrue(body.indexOf("IllegalArgumentException") > -1); - assertNotNull(cause.getResponseHeaders()); - String type = cause.getResponseHeaders().get(Exchange.CONTENT_TYPE); - assertTrue(type.startsWith("text/plain")); - } - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - public void configure() throws Exception { - errorHandler(noErrorHandler()); - from("jetty:http://localhost:{{port}}/myapp/myservice";).process(new MyBookService()); - } - }; - } - - public class MyBookService implements Processor { - public void process(Exchange exchange) throws Exception { - throw new IllegalArgumentException("Damm"); - } - } - -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyResponseBufferSizeTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyResponseBufferSizeTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyResponseBufferSizeTest.java deleted file mode 100644 index 84baa2c..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyResponseBufferSizeTest.java +++ /dev/null @@ -1,40 +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; - -public class JettyResponseBufferSizeTest extends BaseJettyTest { - - @Test - public void testSimple() throws Exception { - String result = template.requestBody("http://localhost:{{port}}/myapp";, "Camel", String.class); - assertEquals("Hello Camel", result); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - public void configure() throws Exception { - from("jetty:http://localhost:{{port}}/myapp?responseBufferSize=65536";) - .transform(body().prepend("Hello ")); - } - }; - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyRouteTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyRouteTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyRouteTest.java deleted file mode 100644 index f7c4464..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyRouteTest.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 javax.servlet.http.HttpServletRequest; - -import org.apache.camel.Exchange; -import org.apache.camel.Processor; -import org.apache.camel.builder.RouteBuilder; -import org.junit.Test; - -/** - * Unit test for wiki demonstration. - */ -public class JettyRouteTest extends BaseJettyTest { - - @Test - public void testSendToJetty() 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("<html><body>Book 123 is Camel in Action</body></html>", body); - } - - @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); - } - - @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 - - from("jetty://http://localhost:{{port}}/proxyServer";) - .to("http://localhost:{{port2}}/host?bridgeEndpoint=true";); - - from("jetty://http://localhost:{{port2}}/host";).transform(header("host")); - } - }; - } - - // START SNIPPET: e2 - 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); - - // for unit testing - assertEquals("bookid=123", body); - - // send a html response - exchange.getOut().setBody("<html><body>Book 123 is Camel in Action</body></html>"); - } - } - // END SNIPPET: e2 - -} http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyRouteWithSocketPropertiesTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyRouteWithSocketPropertiesTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyRouteWithSocketPropertiesTest.java deleted file mode 100644 index 86ef152..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyRouteWithSocketPropertiesTest.java +++ /dev/null @@ -1,79 +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.Map; - -import javax.servlet.http.HttpServletRequest; - -import org.apache.camel.Exchange; -import org.apache.camel.Processor; -import org.apache.camel.builder.RouteBuilder; -import org.junit.Test; - -/** - * Unit test for wiki demonstration. - */ -public class JettyRouteWithSocketPropertiesTest extends BaseJettyTest { - - @Test - public void testSendToJetty() 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("<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 - // define socket connector properties - Map<String, Object> properties = new HashMap<String, Object>(); - properties.put("acceptors", 4); - properties.put("statsOn", "false"); - properties.put("soLingerTime", "5000"); - - JettyHttpComponent jetty = getContext().getComponent("jetty", JettyHttpComponent.class); - jetty.setSocketConnectorProperties(properties); - // END SNIPPET: e1 - - from("jetty:http://localhost:{{port}}/myapp/myservice";).process(new MyBookService()); - } - }; - } - - 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); - - // 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/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyRouteWithUnknownSocketPropertiesTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyRouteWithUnknownSocketPropertiesTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyRouteWithUnknownSocketPropertiesTest.java deleted file mode 100644 index 8b5fedd..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyRouteWithUnknownSocketPropertiesTest.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.util.HashMap; -import java.util.Map; - -import org.apache.camel.builder.RouteBuilder; -import org.eclipse.jetty.server.Server; -import org.junit.Test; - -public class JettyRouteWithUnknownSocketPropertiesTest extends BaseJettyTest { - - @Override - public boolean isUseRouteBuilder() { - return false; - } - - @Test - public void testUnknownProperty() throws Exception { - if (!Server.getVersion().startsWith("8")) { - // SocketConnector props do not work for jetty 9 - return; - } - context.addRoutes(new RouteBuilder() { - @Override - public void configure() throws Exception { - // define socket connector properties - Map<String, Object> properties = new HashMap<String, Object>(); - properties.put("acceptors", 4); - properties.put("statsOn", "false"); - properties.put("soLingerTime", "5000"); - properties.put("doesNotExist", 2000); - - JettyHttpComponent jetty = getContext().getComponent("jetty", JettyHttpComponent.class); - jetty.setSocketConnectorProperties(properties); - - from("jetty:http://localhost:{{port}}/myapp/myservice";).to("log:foo"); - } - }); - try { - context.start(); - fail("Should have thrown exception"); - } catch (IllegalArgumentException e) { - assertTrue(e.getMessage().endsWith("Unknown parameters=[{doesNotExist=2000}]")); - } - } - -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyRouteWithUnknownSslSocketPropertiesTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyRouteWithUnknownSslSocketPropertiesTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyRouteWithUnknownSslSocketPropertiesTest.java deleted file mode 100644 index 72d913d..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettyRouteWithUnknownSslSocketPropertiesTest.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.util.HashMap; -import java.util.Map; - -import org.apache.camel.builder.RouteBuilder; -import org.eclipse.jetty.server.Server; -import org.junit.Test; - -public class JettyRouteWithUnknownSslSocketPropertiesTest extends BaseJettyTest { - - @Override - public boolean isUseRouteBuilder() { - return false; - } - - @Test - public void testUnknownProperty() throws Exception { - if (!Server.getVersion().startsWith("8")) { - // SocketConnector props do not work for jetty 9 - return; - } - context.addRoutes(new RouteBuilder() { - @Override - public void configure() throws Exception { - // define socket connector properties - Map<String, Object> properties = new HashMap<String, Object>(); - properties.put("acceptors", 4); - properties.put("statsOn", "false"); - properties.put("soLingerTime", "5000"); - properties.put("doesNotExist", 2000); - - JettyHttpComponent jetty = getContext().getComponent("jetty", JettyHttpComponent.class); - jetty.setSslSocketConnectorProperties(properties); - - from("jetty:https://localhost:{{port}}/myapp/myservice";).to("log:foo"); - } - }); - try { - context.start(); - fail("Should have thrown exception"); - } catch (IllegalArgumentException e) { - assertTrue("Actual message: " + e.getMessage(), e.getMessage().endsWith("Unknown parameters=[{doesNotExist=2000}]")); - } - } - -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/camel/blob/0d96e56d/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettySessionSupportTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettySessionSupportTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettySessionSupportTest.java deleted file mode 100644 index 0af49a0..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/JettySessionSupportTest.java +++ /dev/null @@ -1,70 +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 JettySessionSupportTest extends BaseJettyTest { - - @Override - public boolean isUseRouteBuilder() { - return false; - } - - @Test - public void testJettySessionSupportInvalid() throws Exception { - context.addRoutes(new RouteBuilder() { - @Override - public void configure() throws Exception { - from("jetty:http://localhost:{{port}}/hello";).to("mock:foo"); - - from("jetty:http://localhost:{{port}}/bye?sessionSupport=true";).to("mock:bar"); - } - }); - try { - context.start(); - fail("Should have thrown an exception"); - } catch (IllegalStateException e) { - assertEquals("Server has already been started. Cannot enabled sessionSupport on http:localhost:" + getPort(), e.getMessage()); - } - } - - @Test - public void testJettySessionSupportOk() throws Exception { - context.addRoutes(new RouteBuilder() { - @Override - public void configure() throws Exception { - from("jetty:http://localhost:{{port}}/hello?sessionSupport=true";).transform(simple("Bye ${body}")); - } - }); - context.start(); - - try { - String reply = template.requestBody("http://localhost:{{port}}/hello";, "World", String.class); - assertEquals("Bye World", reply); - - reply = template.requestBody("http://localhost:{{port}}/hello";, "Moon", String.class); - assertEquals("Bye Moon", reply); - } finally { - context.stop(); - } - } -}
