http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/jettyproducer/JettyProducerHttpsRouteTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/jettyproducer/JettyProducerHttpsRouteTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/jettyproducer/JettyProducerHttpsRouteTest.java deleted file mode 100644 index bb39070..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/jettyproducer/JettyProducerHttpsRouteTest.java +++ /dev/null @@ -1,49 +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.jettyproducer; - -import org.apache.camel.RuntimeCamelException; -import org.apache.camel.component.jetty.HttpsRouteTest; -import org.apache.camel.component.mock.MockEndpoint; -import org.junit.Test; - -public class JettyProducerHttpsRouteTest extends HttpsRouteTest { - - public String getHttpProducerScheme() { - return "jetty://https://";; - } - - @Test - public void testEndpointWithoutHttps() throws Exception { - // these tests does not run well on Windows - if (isPlatform("windows")) { - return; - } - - // give Jetty time to startup properly - Thread.sleep(1000); - - MockEndpoint mockEndpoint = resolveMandatoryEndpoint("mock:a", MockEndpoint.class); - try { - template.sendBodyAndHeader("jetty://http://localhost:"; + port1 + "/test", expectedBody, "Content-Type", "application/xml"); - fail("expect exception on access to https endpoint via http"); - } catch (RuntimeCamelException expected) { - } - assertTrue("mock endpoint was not called", mockEndpoint.getExchanges().isEmpty()); - } - -} \ No newline at end of file
http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/jettyproducer/MyCoolBean.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/jettyproducer/MyCoolBean.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/jettyproducer/MyCoolBean.java deleted file mode 100644 index b93fb26..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/jettyproducer/MyCoolBean.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.jettyproducer; - -import java.io.Serializable; - -/** - * @version - */ -public class MyCoolBean implements Serializable { - - private static final long serialVersionUID = 1L; - private final int id; - private final String name; - - public MyCoolBean(int id, String name) { - this.id = id; - this.name = name; - } - - public int getId() { - return id; - } - - public String getName() { - return name; - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/jettyproducer/MyInputStream.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/jettyproducer/MyInputStream.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/jettyproducer/MyInputStream.java deleted file mode 100644 index 94fa5d0..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/jettyproducer/MyInputStream.java +++ /dev/null @@ -1,35 +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.jettyproducer; - -import java.io.ByteArrayInputStream; - -public class MyInputStream extends ByteArrayInputStream { - private boolean closed; - - public MyInputStream(byte[] buf) { - super(buf); - } - - public void close() { - closed = true; - } - - public boolean isClosed() { - return closed; - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/manual/JettyManual.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/manual/JettyManual.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/manual/JettyManual.java deleted file mode 100644 index a012ded..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/manual/JettyManual.java +++ /dev/null @@ -1,62 +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.manual; - -import org.apache.camel.Exchange; -import org.apache.camel.Processor; -import org.apache.camel.builder.RouteBuilder; -import org.apache.camel.component.mock.MockEndpoint; -import org.apache.camel.test.AvailablePortFinder; -import org.apache.camel.test.junit4.CamelTestSupport; -import org.junit.Ignore; -import org.junit.Test; - -/** - * Used for manual unit test, eg to curl to upload a file with: - * curl -F data=@src/test/data/plain.txt http://localhost:9080/myapp/myservice - * - * @version - */ -public class JettyManual extends CamelTestSupport { - - @Test - @Ignore - public void testManual() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:result"); - mock.expectedMinimumMessageCount(1); - - assertMockEndpointsSatisfied(); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - public void configure() throws Exception { - from("jetty:http://localhost:"; + AvailablePortFinder.getNextAvailable() + "/ myapp / myservice") - .process(new Processor() { - public void process(Exchange exchange) throws Exception { - String body = exchange.getIn().getBody(String.class); - assertNotNull("Body should not be null", body); - } - }) - .transform(constant("OK")).setHeader("Content-Type", constant("text/plain")) - .to("mock:result"); - } - }; - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/HttpClientProxyTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/HttpClientProxyTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/HttpClientProxyTest.java deleted file mode 100644 index e2e245f..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/HttpClientProxyTest.java +++ /dev/null @@ -1,87 +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.proxy; - -import java.lang.reflect.UndeclaredThrowableException; - -import org.apache.camel.CamelExecutionException; -import org.apache.camel.builder.ProxyBuilder; -import org.apache.camel.builder.RouteBuilder; -import org.apache.camel.component.http.HttpOperationFailedException; -import org.apache.camel.component.jetty.BaseJettyTest; -import org.junit.Test; - -/** - * @version - */ -public class HttpClientProxyTest extends BaseJettyTest { - - @Test - public void testHttpClientNoProxyOk() throws Exception { - String out = template.requestBody("direct:cool", "World", String.class); - assertEquals("Hello World", out); - } - - @Test - public void testHttpClientNoProxyException() throws Exception { - try { - template.requestBody("direct:cool", "Kaboom", String.class); - fail("Should have thrown exception"); - } catch (CamelExecutionException e) { - HttpOperationFailedException cause = assertIsInstanceOf(HttpOperationFailedException.class, e.getCause()); - assertEquals(500, cause.getStatusCode()); - assertNotNull(cause.getResponseBody()); - assertTrue(cause.getResponseBody().contains("MyAppException")); - } - } - - @Test - public void testHttpClientProxyOk() throws Exception { - MyCoolService proxy = new ProxyBuilder(context).endpoint("direct:cool").build(MyCoolService.class); - String out = proxy.hello("World"); - - assertEquals("Hello World", out); - } - - @Test - public void testHttpClientProxyException() throws Exception { - MyCoolService proxy = new ProxyBuilder(context).endpoint("direct:cool").build(MyCoolService.class); - try { - proxy.hello("Kaboom"); - fail("Should have thrown exception"); - } catch (UndeclaredThrowableException e) { - HttpOperationFailedException cause = assertIsInstanceOf(HttpOperationFailedException.class, e.getCause()); - assertEquals(500, cause.getStatusCode()); - assertNotNull(cause.getResponseBody()); - assertTrue(cause.getResponseBody().contains("MyAppException")); - } - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - from("direct:cool") - .to("http://localhost:{{port}}/myapp/myservice";); - - from("jetty:http://localhost:{{port}}/myapp/myservice";) - .bean(MyCoolServiceBean.class); - } - }; - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/HttpClientProxyTransferExceptionTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/HttpClientProxyTransferExceptionTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/HttpClientProxyTransferExceptionTest.java deleted file mode 100644 index 4d15059..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/HttpClientProxyTransferExceptionTest.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.proxy; - -import org.apache.camel.CamelExecutionException; -import org.apache.camel.builder.ProxyBuilder; -import org.apache.camel.builder.RouteBuilder; -import org.apache.camel.component.jetty.BaseJettyTest; -import org.junit.Test; - -/** - * @version - */ -public class HttpClientProxyTransferExceptionTest extends BaseJettyTest { - - @Test - public void testHttpClientNoProxyOk() throws Exception { - String out = template.requestBody("direct:cool", "World", String.class); - assertEquals("Hello World", out); - } - - @Test - public void testHttpClientNoProxyException() throws Exception { - try { - template.requestBody("direct:cool", "Kaboom"); - fail("Should have thrown an exception"); - } catch (CamelExecutionException e) { - MyAppException cause = assertIsInstanceOf(MyAppException.class, e.getCause()); - assertNotNull(cause); - assertEquals("Kaboom", cause.getName()); - } - } - - @Test - public void testHttpClientProxyOk() throws Exception { - MyCoolService proxy = new ProxyBuilder(context).endpoint("direct:cool").build(MyCoolService.class); - String out = proxy.hello("World"); - - assertEquals("Hello World", out); - } - - @Test - public void testHttpClientProxyException() throws Exception { - MyCoolService proxy = new ProxyBuilder(context).endpoint("direct:cool").build(MyCoolService.class); - try { - proxy.hello("Kaboom"); - fail("Should have thrown exception"); - } catch (MyAppException e) { - assertEquals("Kaboom", e.getName()); - } - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - from("direct:cool") - .to("http://localhost:{{port}}/myapp/myservice?transferException=true";); - - from("jetty:http://localhost:{{port}}/myapp/myservice?transferException=true";) - .bean(MyCoolServiceBean.class); - } - }; - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/JettyChuckedFalseTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/JettyChuckedFalseTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/JettyChuckedFalseTest.java deleted file mode 100644 index ebcc556..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/JettyChuckedFalseTest.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.proxy; - -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.jetty.BaseJettyTest; -import org.apache.camel.converter.stream.CachedOutputStream; -import org.apache.camel.util.IOHelper; -import org.junit.Test; - -public class JettyChuckedFalseTest extends BaseJettyTest { - - @Test - public void runningTest() throws Exception { - Exchange exchange = template.request("http://localhost:{{port}}/test";, new Processor() { - @Override - public void process(Exchange exchange) throws Exception { - // we do nothing here, so http producer will send a GET method request - } - - }); - Message out = exchange.getOut(); - // make sure we have the content-length header - String len = out.getHeader(Exchange.CONTENT_LENGTH, String.class); - assertEquals("We should have the content-length header here.", "20", len); - String response = out.getBody(String.class); - assertEquals("Get a wrong response", "This is hello world.", response); - } - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - - from("jetty:http://localhost:{{port}}/test?matchOnUriPrefix=true&chunked=false";) - .to("http://localhost:{{port2}}/other?bridgeEndpoint=true";); - - from("jetty:http://localhost:{{port2}}/other";).process(new Processor() { - - @Override - public void process(Exchange exchange) throws Exception { - exchange.getOut().setHeader(Exchange.CONTENT_TYPE, "image/jpeg"); - CachedOutputStream stream = new CachedOutputStream(exchange); - stream.write("This is hello world.".getBytes()); - exchange.getOut().setBody(stream.getInputStream()); - IOHelper.close(stream); - } - }); - } - }; - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/MyAppException.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/MyAppException.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/MyAppException.java deleted file mode 100644 index ba20cfa..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/MyAppException.java +++ /dev/null @@ -1,35 +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.proxy; - -/** - * @version - */ -public class MyAppException extends Exception { - - private static final long serialVersionUID = 1L; - private final String name; - - public MyAppException(String msg, String name) { - super(msg); - this.name = name; - } - - public String getName() { - return name; - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/MyCoolService.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/MyCoolService.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/MyCoolService.java deleted file mode 100644 index 0b2bdea..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/MyCoolService.java +++ /dev/null @@ -1,25 +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.proxy; - -/** - * @version - */ -public interface MyCoolService { - - String hello(String name) throws MyAppException; -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/MyCoolServiceBean.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/MyCoolServiceBean.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/MyCoolServiceBean.java deleted file mode 100644 index 7746a6b..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/proxy/MyCoolServiceBean.java +++ /dev/null @@ -1,31 +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.proxy; - -/** - * @version - */ -public class MyCoolServiceBean implements MyCoolService { - - public String hello(String name) throws MyAppException { - if ("Kaboom".equals(name)) { - throw new MyAppException("Invalid name", "Kaboom"); - } - - return "Hello " + name; - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/CountryPojo.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/CountryPojo.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/CountryPojo.java deleted file mode 100644 index 022da99..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/CountryPojo.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.rest; - -public class CountryPojo { - - private String iso; - private String country; - - public String getIso() { - return iso; - } - - public void setIso(String iso) { - this.iso = iso; - } - - public String getCountry() { - return country; - } - - public void setCountry(String country) { - this.country = country; - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/JettyRestRedirectTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/JettyRestRedirectTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/JettyRestRedirectTest.java deleted file mode 100644 index 4838ec0..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/JettyRestRedirectTest.java +++ /dev/null @@ -1,57 +0,0 @@ -/** - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.camel.component.jetty.rest; - -import org.apache.camel.Exchange; -import org.apache.camel.Processor; -import org.apache.camel.builder.RouteBuilder; -import org.apache.camel.component.jetty.BaseJettyTest; -import org.junit.Test; - -public class JettyRestRedirectTest extends BaseJettyTest { - - @Test - public void testRedirectInvocation() throws Exception { - String response = template.requestBody("jetty:http://localhost:"; + getPort2() + "/metadata/profile/tag?httpClient.supportRedirect=true", "<hello>Camel</hello>", String.class); - assertEquals("It should support the redirect out of box.", "Mock profile", response); - } - - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - - return new RouteBuilder() { - public void configure() { - restConfiguration().component("jetty").host("localhost").scheme("http").port(getPort2()); - rest("/metadata/profile") - .get("/{id}").to("direct:profileLookup") - .post("/tag").to("direct:tag"); - - from("direct:profileLookup").transform().constant("Mock profile"); - from("direct:tag").log("${headers}").process(new Processor() { - @Override - public void process(Exchange ex) throws Exception { - ex.getOut().setHeader(Exchange.HTTP_RESPONSE_CODE, 302); - ex.getOut().setHeader("location", "/metadata/profile/1"); - } - }).log("${headers}").transform().constant("Redirecting..."); - } - }; - } - -} - http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyBindingModeAutoWithJsonTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyBindingModeAutoWithJsonTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyBindingModeAutoWithJsonTest.java deleted file mode 100644 index 43ec8f3..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyBindingModeAutoWithJsonTest.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.rest; - -import org.apache.camel.builder.RouteBuilder; -import org.apache.camel.component.jetty.BaseJettyTest; -import org.apache.camel.component.mock.MockEndpoint; -import org.apache.camel.model.rest.RestBindingMode; -import org.junit.Test; - -public class RestJettyBindingModeAutoWithJsonTest extends BaseJettyTest { - - @Test - public void testBindingMode() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:input"); - mock.expectedMessageCount(1); - mock.message(0).body().isInstanceOf(UserPojo.class); - - String body = "{\"id\": 123, \"name\": \"Donald Duck\"}"; - template.sendBody("http://localhost:"; + getPort() + "/users/new", body); - - assertMockEndpointsSatisfied(); - - UserPojo user = mock.getReceivedExchanges().get(0).getIn().getBody(UserPojo.class); - assertNotNull(user); - assertEquals(123, user.getId()); - assertEquals("Donald Duck", user.getName()); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - restConfiguration().component("jetty").host("localhost").port(getPort()).bindingMode(RestBindingMode.auto); - - // use the rest DSL to define the rest services - rest("/users/") - .post("new").consumes("application/json").type(UserPojo.class) - .to("mock:input"); - } - }; - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyBindingModeAutoWithXmlTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyBindingModeAutoWithXmlTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyBindingModeAutoWithXmlTest.java deleted file mode 100644 index 2db5138..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyBindingModeAutoWithXmlTest.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.rest; - -import org.apache.camel.builder.RouteBuilder; -import org.apache.camel.component.jetty.BaseJettyTest; -import org.apache.camel.component.mock.MockEndpoint; -import org.apache.camel.model.rest.RestBindingMode; -import org.junit.Test; - -public class RestJettyBindingModeAutoWithXmlTest extends BaseJettyTest { - - @Test - public void testBindingMode() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:input"); - mock.expectedMessageCount(1); - mock.message(0).body().isInstanceOf(UserJaxbPojo.class); - - String body = "<user name=\"Donald Duck\" id=\"123\"></user>"; - template.sendBody("http://localhost:"; + getPort() + "/users/new", body); - - assertMockEndpointsSatisfied(); - - UserJaxbPojo user = mock.getReceivedExchanges().get(0).getIn().getBody(UserJaxbPojo.class); - assertNotNull(user); - assertEquals(123, user.getId()); - assertEquals("Donald Duck", user.getName()); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - restConfiguration().component("jetty").host("localhost").port(getPort()).bindingMode(RestBindingMode.auto); - - // use the rest DSL to define the rest services - rest("/users/") - .post("new").consumes("application/xml").type(UserJaxbPojo.class) - .to("mock:input"); - } - }; - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyBindingModeJsonTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyBindingModeJsonTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyBindingModeJsonTest.java deleted file mode 100644 index 103cdc4..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyBindingModeJsonTest.java +++ /dev/null @@ -1,75 +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.rest; - -import org.apache.camel.builder.RouteBuilder; -import org.apache.camel.component.jetty.BaseJettyTest; -import org.apache.camel.component.mock.MockEndpoint; -import org.apache.camel.model.rest.RestBindingMode; -import org.junit.Test; - -public class RestJettyBindingModeJsonTest extends BaseJettyTest { - - @Test - public void testBindingMode() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:input"); - mock.expectedMessageCount(1); - mock.message(0).body().isInstanceOf(UserJaxbPojo.class); - - String body = "{\"id\": 123, \"name\": \"Donald Duck\"}"; - template.sendBody("http://localhost:"; + getPort() + "/users/new", body); - - assertMockEndpointsSatisfied(); - - UserJaxbPojo user = mock.getReceivedExchanges().get(0).getIn().getBody(UserJaxbPojo.class); - assertNotNull(user); - assertEquals(123, user.getId()); - assertEquals("Donald Duck", user.getName()); - } - - @Test - public void testBindingModeWrong() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:input"); - mock.expectedMessageCount(0); - - // we bind to json, but send in xml, which is not possible - String body = "<user name=\"Donald Duck\" id=\"123\"></user>"; - try { - template.sendBody("http://localhost:"; + getPort() + "/users/new", body); - fail("Should have thrown exception"); - } catch (Exception e) { - // expected - } - - assertMockEndpointsSatisfied(); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - restConfiguration().component("jetty").host("localhost").port(getPort()).bindingMode(RestBindingMode.json); - - // use the rest DSL to define the rest services - rest("/users/") - .post("new").type(UserJaxbPojo.class) - .to("mock:input"); - } - }; - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyBindingModeXmlTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyBindingModeXmlTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyBindingModeXmlTest.java deleted file mode 100644 index 18ce442..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyBindingModeXmlTest.java +++ /dev/null @@ -1,75 +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.rest; - -import org.apache.camel.builder.RouteBuilder; -import org.apache.camel.component.jetty.BaseJettyTest; -import org.apache.camel.component.mock.MockEndpoint; -import org.apache.camel.model.rest.RestBindingMode; -import org.junit.Test; - -public class RestJettyBindingModeXmlTest extends BaseJettyTest { - - @Test - public void testBindingMode() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:input"); - mock.expectedMessageCount(1); - mock.message(0).body().isInstanceOf(UserJaxbPojo.class); - - String body = "<user name=\"Donald Duck\" id=\"123\"></user>"; - template.sendBody("http://localhost:"; + getPort() + "/users/new", body); - - assertMockEndpointsSatisfied(); - - UserJaxbPojo user = mock.getReceivedExchanges().get(0).getIn().getBody(UserJaxbPojo.class); - assertNotNull(user); - assertEquals(123, user.getId()); - assertEquals("Donald Duck", user.getName()); - } - - @Test - public void testBindingModeWrong() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:input"); - mock.expectedMessageCount(0); - - // we bind to xml, but send in json, which is not possible - String body = "{\"id\": 123, \"name\": \"Donald Duck\"}"; - try { - template.sendBody("http://localhost:"; + getPort() + "/users/new", body); - fail("Should have thrown exception"); - } catch (Exception e) { - // expected - } - - assertMockEndpointsSatisfied(); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - restConfiguration().component("jetty").host("localhost").port(getPort()).bindingMode(RestBindingMode.xml); - - // use the rest DSL to define the rest services - rest("/users/") - .post("new").type(UserJaxbPojo.class) - .to("mock:input"); - } - }; - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyGetTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyGetTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyGetTest.java deleted file mode 100644 index 5022681..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyGetTest.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.rest; - -import org.apache.camel.Exchange; -import org.apache.camel.Processor; -import org.apache.camel.builder.RouteBuilder; -import org.apache.camel.component.jetty.BaseJettyTest; -import org.apache.camel.component.jetty.JettyRestHttpBinding; -import org.apache.camel.impl.JndiRegistry; -import org.junit.Test; - -public class RestJettyGetTest extends BaseJettyTest { - - - @Override - protected JndiRegistry createRegistry() throws Exception { - JndiRegistry jndi = super.createRegistry(); - jndi.bind("mybinding", new JettyRestHttpBinding()); - return jndi; - } - - @Test - public void testJettyProducerGet() throws Exception { - String out = template.requestBody("http://localhost:"; + getPort() + "/users/123/basic", null, String.class); - assertEquals("123;Donald Duck", out); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - // configure to use jetty on localhost with the given port - restConfiguration().component("jetty").host("localhost").port(getPort()).endpointProperty("httpBindingRef", "#mybinding"); - - // use the rest DSL to define the rest services - rest("/users/") - .get("{id}/basic") - .route() - .to("mock:input") - .process(new Processor() { - public void process(Exchange exchange) throws Exception { - String id = exchange.getIn().getHeader("id", String.class); - exchange.getOut().setBody(id + ";Donald Duck"); - } - }); - } - }; - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyPojoInOutTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyPojoInOutTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyPojoInOutTest.java deleted file mode 100644 index 3f9dd28..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyPojoInOutTest.java +++ /dev/null @@ -1,68 +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.rest; - -import org.apache.camel.builder.RouteBuilder; -import org.apache.camel.component.jetty.BaseJettyTest; -import org.apache.camel.model.rest.RestBindingMode; -import org.junit.Test; - -public class RestJettyPojoInOutTest extends BaseJettyTest { - - @Test - public void testJettyPojoInOut() throws Exception { - String body = "{\"id\": 123, \"name\": \"Donald Duck\"}"; - String out = template.requestBody("http://localhost:"; + getPort() + "/users/lives", body, String.class); - - assertNotNull(out); - assertEquals("{\"iso\":\"EN\",\"country\":\"England\"}", out); - } - - @Test - public void testJettyGetRequest() throws Exception { - String out = template.requestBody("http://localhost:"; + getPort() + "/users/lives", null, String.class); - - assertNotNull(out); - assertEquals("{\"iso\":\"EN\",\"country\":\"England\"}", out); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - // configure to use jetty on localhost with the given port - // and enable auto binding mode - restConfiguration().component("jetty").host("localhost").port(getPort()).bindingMode(RestBindingMode.auto); - - // use the rest DSL to define the rest services - rest("/users/") - // just return the default country here - .get("lives").to("direct:start") - .post("lives").type(UserPojo.class).outType(CountryPojo.class) - .route() - .bean(new UserService(), "livesWhere"); - - CountryPojo country = new CountryPojo(); - country.setIso("EN"); - country.setCountry("England"); - from("direct:start").transform().constant(country); - } - }; - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyPostJsonJaxbPojoTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyPostJsonJaxbPojoTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyPostJsonJaxbPojoTest.java deleted file mode 100644 index d71db72..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyPostJsonJaxbPojoTest.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.rest; - -import org.apache.camel.builder.RouteBuilder; -import org.apache.camel.component.jetty.BaseJettyTest; -import org.apache.camel.component.mock.MockEndpoint; -import org.apache.camel.model.rest.RestBindingMode; -import org.junit.Test; - -public class RestJettyPostJsonJaxbPojoTest extends BaseJettyTest { - - @Test - public void testPostJaxbPojo() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:input"); - mock.expectedMessageCount(1); - mock.message(0).body().isInstanceOf(UserJaxbPojo.class); - - String body = "{\"id\": 123, \"name\": \"Donald Duck\"}"; - template.sendBody("http://localhost:"; + getPort() + "/users/new", body); - - assertMockEndpointsSatisfied(); - - UserJaxbPojo user = mock.getReceivedExchanges().get(0).getIn().getBody(UserJaxbPojo.class); - assertNotNull(user); - assertEquals(123, user.getId()); - assertEquals("Donald Duck", user.getName()); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - // configure to use jetty on localhost with the given port - // and enable auto binding mode - restConfiguration().component("jetty").host("localhost").port(getPort()).bindingMode(RestBindingMode.auto); - - // use the rest DSL to define the rest services - rest("/users/") - .post("new").type(UserJaxbPojo.class) - .to("mock:input"); - } - }; - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyPostJsonPojoListTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyPostJsonPojoListTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyPostJsonPojoListTest.java deleted file mode 100644 index 2817cda..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyPostJsonPojoListTest.java +++ /dev/null @@ -1,67 +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.rest; - -import java.util.List; - -import org.apache.camel.builder.RouteBuilder; -import org.apache.camel.component.jetty.BaseJettyTest; -import org.apache.camel.component.mock.MockEndpoint; -import org.apache.camel.model.rest.RestBindingMode; -import org.junit.Test; - -public class RestJettyPostJsonPojoListTest extends BaseJettyTest { - - @Test - public void testPostPojoList() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:input"); - mock.expectedMessageCount(1); - - String body = "[ {\"id\": 123, \"name\": \"Donald Duck\"}, {\"id\": 456, \"name\": \"John Doe\"} ]"; - template.sendBody("http://localhost:"; + getPort() + "/users/new", body); - - assertMockEndpointsSatisfied(); - - List list = mock.getReceivedExchanges().get(0).getIn().getBody(List.class); - assertNotNull(list); - assertEquals(2, list.size()); - - UserPojo user = (UserPojo) list.get(0); - assertEquals(123, user.getId()); - assertEquals("Donald Duck", user.getName()); - user = (UserPojo) list.get(1); - assertEquals(456, user.getId()); - assertEquals("John Doe", user.getName()); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - // configure to use jetty on localhost with the given port - // and enable auto binding mode - restConfiguration().component("jetty").host("localhost").port(getPort()).bindingMode(RestBindingMode.auto); - - // use the rest DSL to define the rest services - rest("/users/") - .post("new").typeList(UserPojo.class) - .to("mock:input"); - } - }; - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyPostJsonPojoTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyPostJsonPojoTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyPostJsonPojoTest.java deleted file mode 100644 index 51ea5ee..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyPostJsonPojoTest.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.rest; - -import org.apache.camel.builder.RouteBuilder; -import org.apache.camel.component.jetty.BaseJettyTest; -import org.apache.camel.component.mock.MockEndpoint; -import org.apache.camel.model.rest.RestBindingMode; -import org.junit.Test; - -public class RestJettyPostJsonPojoTest extends BaseJettyTest { - - @Test - public void testPostPojo() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:input"); - mock.expectedMessageCount(1); - mock.message(0).body().isInstanceOf(UserPojo.class); - - String body = "{\"id\": 123, \"name\": \"Donald Duck\"}"; - template.sendBody("http://localhost:"; + getPort() + "/users/new", body); - - assertMockEndpointsSatisfied(); - - UserPojo user = mock.getReceivedExchanges().get(0).getIn().getBody(UserPojo.class); - assertNotNull(user); - assertEquals(123, user.getId()); - assertEquals("Donald Duck", user.getName()); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - // configure to use jetty on localhost with the given port - // and enable auto binding mode - restConfiguration().component("jetty").host("localhost").port(getPort()).bindingMode(RestBindingMode.auto); - - // use the rest DSL to define the rest services - rest("/users/") - .post("new").type(UserPojo.class) - .to("mock:input"); - } - }; - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyPostXmlJaxbPojoTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyPostXmlJaxbPojoTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyPostXmlJaxbPojoTest.java deleted file mode 100644 index c070725..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestJettyPostXmlJaxbPojoTest.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.rest; - -import org.apache.camel.Exchange; -import org.apache.camel.builder.RouteBuilder; -import org.apache.camel.component.jetty.BaseJettyTest; -import org.apache.camel.component.mock.MockEndpoint; -import org.apache.camel.model.rest.RestBindingMode; -import org.junit.Test; - -public class RestJettyPostXmlJaxbPojoTest extends BaseJettyTest { - - @Test - public void testPostJaxbPojo() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:input"); - mock.expectedMessageCount(1); - mock.message(0).body().isInstanceOf(UserJaxbPojo.class); - - String body = "<user name=\"Donald Duck\" id=\"123\"></user>"; - template.sendBodyAndHeader("http://localhost:"; + getPort() + "/users/new", body, Exchange.CONTENT_TYPE, "text/xml"); - - assertMockEndpointsSatisfied(); - - UserJaxbPojo user = mock.getReceivedExchanges().get(0).getIn().getBody(UserJaxbPojo.class); - assertNotNull(user); - assertEquals(123, user.getId()); - assertEquals("Donald Duck", user.getName()); - } - - @Test - public void testPostJaxbPojoNoContentType() throws Exception { - MockEndpoint mock = getMockEndpoint("mock:input"); - mock.expectedMessageCount(1); - mock.message(0).body().isInstanceOf(UserJaxbPojo.class); - - String body = "<user name=\"Donald Duck\" id=\"456\"></user>"; - template.sendBody("http://localhost:"; + getPort() + "/users/new", body); - - assertMockEndpointsSatisfied(); - - UserJaxbPojo user = mock.getReceivedExchanges().get(0).getIn().getBody(UserJaxbPojo.class); - assertNotNull(user); - assertEquals(456, user.getId()); - assertEquals("Donald Duck", user.getName()); - } - - @Override - protected RouteBuilder createRouteBuilder() throws Exception { - return new RouteBuilder() { - @Override - public void configure() throws Exception { - // configure to use jetty on localhost with the given port - // and enable auto binding mode - restConfiguration().component("jetty").host("localhost").port(getPort()).bindingMode(RestBindingMode.auto); - - // use the rest DSL to define the rest services - rest("/users/") - .post("new").type(UserJaxbPojo.class) - .to("mock:input"); - } - }; - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestPathMatchingTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestPathMatchingTest.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestPathMatchingTest.java deleted file mode 100644 index 5e0d726..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/RestPathMatchingTest.java +++ /dev/null @@ -1,85 +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.rest; - -import junit.framework.TestCase; -import org.apache.camel.component.jetty.JettyRestServletResolveConsumerStrategy; - -public class RestPathMatchingTest extends TestCase { - - private JettyRestServletResolveConsumerStrategy matcher = new JettyRestServletResolveConsumerStrategy(); - - public void testRestPathMatcher() throws Exception { - assertTrue(matcher.matchRestPath("/foo/", "/foo/", true)); - assertTrue(matcher.matchRestPath("/foo/", "foo/", true)); - assertTrue(matcher.matchRestPath("/foo/", "foo", true)); - assertTrue(matcher.matchRestPath("foo/", "foo", true)); - assertTrue(matcher.matchRestPath("foo", "foo", true)); - assertTrue(matcher.matchRestPath("foo/", "foo", true)); - assertTrue(matcher.matchRestPath("/foo/", "foo", true)); - - assertTrue(matcher.matchRestPath("/foo/1234/list/2014", "/foo/1234/list/2014", true)); - assertTrue(matcher.matchRestPath("/foo/1234/list/2014/", "/foo/1234/list/2014", true)); - assertTrue(matcher.matchRestPath("/foo/1234/list/2014", "/foo/1234/list/2014/", true)); - assertTrue(matcher.matchRestPath("/foo/1234/list/2014/", "/foo/1234/list/2014/", true)); - assertTrue(matcher.matchRestPath("/foo/1234/list/2014", "/foo/{user}/list/{year}", true)); - - assertFalse(matcher.matchRestPath("/foo/", "/bar/", true)); - assertFalse(matcher.matchRestPath("/foo/1234/list/2014", "/foo/1234/list/2015", true)); - assertFalse(matcher.matchRestPath("/foo/1234/list/2014/", "/foo/1234/list/2015", true)); - assertFalse(matcher.matchRestPath("/foo/1234/list/2014", "/foo/1234/list/2015/", true)); - assertFalse(matcher.matchRestPath("/foo/1234/list/2014/", "/foo/1234/list/2015/", true)); - assertFalse(matcher.matchRestPath("/foo/1234/list/2014", "/foo/{user}/list/", true)); - - assertTrue(matcher.matchRestPath("/foo/1/list/2", "/foo/{user}/list/{year}", true)); - assertTrue(matcher.matchRestPath("/foo/1234567890/list/2", "/foo/{user}/list/{year}", true)); - assertTrue(matcher.matchRestPath("/foo/1234567890/list/1234567890", "/foo/{user}/list/{year}", true)); - - assertTrue(matcher.matchRestPath("/123/list/2014", "/{user}/list/{year}", true)); - assertTrue(matcher.matchRestPath("/1234567890/list/2014", "/{user}/list/{year}", true)); - } - - public void testRestPathMatcherNoWildcard() throws Exception { - assertTrue(matcher.matchRestPath("/foo/", "/foo/", false)); - assertTrue(matcher.matchRestPath("/foo/", "foo/", false)); - assertTrue(matcher.matchRestPath("/foo/", "foo", false)); - assertTrue(matcher.matchRestPath("foo/", "foo", false)); - assertTrue(matcher.matchRestPath("foo", "foo", false)); - assertTrue(matcher.matchRestPath("foo/", "foo", false)); - assertTrue(matcher.matchRestPath("/foo/", "foo", false)); - - assertTrue(matcher.matchRestPath("/foo/1234/list/2014", "/foo/1234/list/2014", false)); - assertTrue(matcher.matchRestPath("/foo/1234/list/2014/", "/foo/1234/list/2014", false)); - assertTrue(matcher.matchRestPath("/foo/1234/list/2014", "/foo/1234/list/2014/", false)); - assertTrue(matcher.matchRestPath("/foo/1234/list/2014/", "/foo/1234/list/2014/", false)); - assertTrue(matcher.matchRestPath("/foo/1234/list/2014", "/foo/{user}/list/{year}", true)); - - assertFalse(matcher.matchRestPath("/foo/", "/bar/", false)); - assertFalse(matcher.matchRestPath("/foo/1234/list/2014", "/foo/1234/list/2015", false)); - assertFalse(matcher.matchRestPath("/foo/1234/list/2014/", "/foo/1234/list/2015", false)); - assertFalse(matcher.matchRestPath("/foo/1234/list/2014", "/foo/1234/list/2015/", false)); - assertFalse(matcher.matchRestPath("/foo/1234/list/2014/", "/foo/1234/list/2015/", false)); - assertFalse(matcher.matchRestPath("/foo/1234/list/2014", "/foo/{user}/list/", false)); - - assertFalse(matcher.matchRestPath("/foo/1/list/2", "/foo/{user}/list/{year}", false)); - assertFalse(matcher.matchRestPath("/foo/1234567890/list/2", "/foo/{user}/list/{year}", false)); - assertFalse(matcher.matchRestPath("/foo/1234567890/list/1234567890", "/foo/{user}/list/{year}", false)); - - assertFalse(matcher.matchRestPath("/123/list/2014", "/{user}/list/{year}", false)); - assertFalse(matcher.matchRestPath("/1234567890/list/2014", "/{user}/list/{year}", false)); - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/UserJaxbPojo.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/UserJaxbPojo.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/UserJaxbPojo.java deleted file mode 100644 index cc7d85c..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/UserJaxbPojo.java +++ /dev/null @@ -1,48 +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.rest; - -import javax.xml.bind.annotation.XmlAccessType; -import javax.xml.bind.annotation.XmlAccessorType; -import javax.xml.bind.annotation.XmlAttribute; -import javax.xml.bind.annotation.XmlRootElement; - -@XmlRootElement(name = "user") -@XmlAccessorType(XmlAccessType.FIELD) -public class UserJaxbPojo { - - @XmlAttribute - private int id; - @XmlAttribute - private String name; - - public int getId() { - return id; - } - - public void setId(int id) { - this.id = id; - } - - public String getName() { - return name; - } - - public void setName(String name) { - this.name = name; - } -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/UserPojo.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/UserPojo.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/UserPojo.java deleted file mode 100644 index caf65e7..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/UserPojo.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.rest; - -public class UserPojo { - - private int id; - private String name; - - public int getId() { - return id; - } - - public void setId(int id) { - this.id = id; - } - - public String getName() { - return name; - } - - public void setName(String name) { - this.name = name; - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/UserService.java ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/UserService.java b/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/UserService.java deleted file mode 100644 index 7665b40..0000000 --- a/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/rest/UserService.java +++ /dev/null @@ -1,33 +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.rest; - -public class UserService { - - public CountryPojo livesWhere(UserPojo user) { - CountryPojo answer = new CountryPojo(); - if (user.getId() < 500) { - answer.setIso("EN"); - answer.setCountry("England"); - } else { - answer.setIso("SE"); - answer.setCountry("Sweden"); - } - return answer; - } - -} http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/resources/java.jpg ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/resources/java.jpg b/components/camel-jetty/src/test/resources/java.jpg deleted file mode 100644 index dc59bee..0000000 Binary files a/components/camel-jetty/src/test/resources/java.jpg and /dev/null differ http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/resources/jsse/localhost-alias.ks ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/resources/jsse/localhost-alias.ks b/components/camel-jetty/src/test/resources/jsse/localhost-alias.ks deleted file mode 100644 index 33fb9b6..0000000 Binary files a/components/camel-jetty/src/test/resources/jsse/localhost-alias.ks and /dev/null differ http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/resources/jsse/localhost.ks ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/resources/jsse/localhost.ks b/components/camel-jetty/src/test/resources/jsse/localhost.ks deleted file mode 100644 index f285418..0000000 Binary files a/components/camel-jetty/src/test/resources/jsse/localhost.ks and /dev/null differ http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/resources/log4j.properties ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/resources/log4j.properties b/components/camel-jetty/src/test/resources/log4j.properties deleted file mode 100644 index 7be001b..0000000 --- a/components/camel-jetty/src/test/resources/log4j.properties +++ /dev/null @@ -1,47 +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. -## --------------------------------------------------------------------------- - -# -# The logging properties used during tests.. -# -# -# The logging properties used for eclipse testing, We want to see debug output on the console. -# -log4j.rootLogger=INFO, file - -# uncomment the following to enable camel debugging -#log4j.logger.org.apache.camel.component.jetty=TRACE -#log4j.logger.org.apache.camel.component.jetty.CamelContinuationServlet=TRACE -#log4j.logger.org.apache.camel.component.http.CamelServlet=TRACE -#log4j.logger.org.apache.camel.component.jetty.JettyContentExchange=DEBUG -#log4j.logger.org.apache.camel.component.http=TRACE -#log4j.logger.org.apache.camel=DEBUG -#log4j.logger.org.apache.camel.impl.converter.PropertyEditorTypeConverter=TRACE - -#log4j.logger.org.eclipse.jetty=TRACE - -# CONSOLE appender not used by default -log4j.appender.out=org.apache.log4j.ConsoleAppender -log4j.appender.out.layout=org.apache.log4j.PatternLayout -#log4j.appender.out.layout.ConversionPattern=[%30.30t] %-30.30c{1} %-5p %m%n -log4j.appender.out.layout.ConversionPattern=%d [%-15.15t] %-5p %-30.30c{1} - %m%n - -# File appender -log4j.appender.file=org.apache.log4j.FileAppender -log4j.appender.file.layout=org.apache.log4j.PatternLayout -log4j.appender.file.layout.ConversionPattern=%d [%-15.15t] %-5p %-30.30c{1} - %m%n -log4j.appender.file.file=target/camel-jetty-test.log http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/resources/myRealm.properties ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/resources/myRealm.properties b/components/camel-jetty/src/test/resources/myRealm.properties deleted file mode 100644 index 2f8f01e..0000000 --- a/components/camel-jetty/src/test/resources/myRealm.properties +++ /dev/null @@ -1,18 +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. -## --------------------------------------------------------------------------- - -donald: duck, user \ No newline at end of file http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/resources/org/apache/camel/component/jetty/JettyComponentSpringConfiguredTest.xml ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/resources/org/apache/camel/component/jetty/JettyComponentSpringConfiguredTest.xml b/components/camel-jetty/src/test/resources/org/apache/camel/component/jetty/JettyComponentSpringConfiguredTest.xml deleted file mode 100644 index 0809f5b..0000000 --- a/components/camel-jetty/src/test/resources/org/apache/camel/component/jetty/JettyComponentSpringConfiguredTest.xml +++ /dev/null @@ -1,42 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<!-- - 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. ---> -<beans xmlns="http://www.springframework.org/schema/beans"; - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; - xsi:schemaLocation=" - http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd - http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd - "> - - <bean id="jetty2" class="org.apache.camel.component.jetty8.JettyHttpComponent8"> - <property name="enableJmx" value="true"/> - <property name="minThreads" value="10"/> - <property name="maxThreads" value="50"/> - </bean> - - <camelContext id="camel" xmlns="http://camel.apache.org/schema/spring";> - - <route> - <from uri="jetty2:http://localhost:9090/myapp"/> - <transform> - <simple>Hello ${body}</simple> - </transform> - </route> - - </camelContext> - -</beans> http://git-wip-us.apache.org/repos/asf/camel/blob/a59becd7/components/camel-jetty/src/test/resources/org/apache/camel/component/jetty/jetty-https.xml ---------------------------------------------------------------------- diff --git a/components/camel-jetty/src/test/resources/org/apache/camel/component/jetty/jetty-https.xml b/components/camel-jetty/src/test/resources/org/apache/camel/component/jetty/jetty-https.xml deleted file mode 100644 index b58cf77..0000000 --- a/components/camel-jetty/src/test/resources/org/apache/camel/component/jetty/jetty-https.xml +++ /dev/null @@ -1,55 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<!-- - 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. ---> -<beans xmlns="http://www.springframework.org/schema/beans"; - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; - xsi:schemaLocation=" - http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd - http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd - "> - <bean id="jetty" class="org.apache.camel.component.jetty8.JettyHttpComponent8"> - <property name="sslPassword" value="changeit"/> - <property name="sslKeyPassword" value="changeit"/> - <property name="keystore" value="src/test/resources/jsse/localhost.ks"/> - </bean> - - - <bean id="dynaPort" class="org.springframework.beans.factory.config.MethodInvokingFactoryBean"> - <property name="targetClass"> - <value>org.apache.camel.test.AvailablePortFinder</value> - </property> - <property name="targetMethod"> - <value>getNextAvailable</value> - </property> - <property name="arguments"> - <list> - <value>9000</value> - </list> - </property> - </bean> - - - <camelContext id="camel" xmlns="http://camel.apache.org/schema/spring";> - <endpoint id="input1" uri="jetty:https://localhost:#{dynaPort}/test"/> - - <route> - <from ref="input1"/> - <to uri="mock:a"/> - </route> - </camelContext> - -</beans>
