You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by cs...@apache.org on 2015/01/19 14:44:30 UTC
[16/24] camel git commit: CAMEL-8239 Split jetty8 and jetty9 support
into separate modules
http://git-wip-us.apache.org/repos/asf/camel/blob/8b2a8877/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/8b2a8877/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/8b2a8877/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/8b2a8877/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/8b2a8877/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/8b2a8877/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/8b2a8877/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/8b2a8877/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/8b2a8877/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/8b2a8877/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/8b2a8877/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/8b2a8877/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/8b2a8877/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/8b2a8877/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/8b2a8877/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/8b2a8877/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/8b2a8877/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/8b2a8877/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/8b2a8877/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/8b2a8877/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/8b2a8877/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/8b2a8877/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/8b2a8877/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();
- }
- }
-}